SyncSession

class aerospike_sdk.sync.session.SyncSession[source]

Bases: object

Run session-scoped reads and writes without async/await.

Construct via SyncClient.create_session, not directly.

See also

Session: Async equivalent.

__init__(client, behavior)[source]

Attach a client and behavior; prefer SyncClient.create_session().

property behavior: Behavior

The behavior configuration for this session.

property client: SyncClient

The owning SyncClient.

get_current_transaction()[source]

Return the active transaction for this session, or None.

Return type:

Optional[Txn]

get(key, *, bins=None)[source]

Direct single-key read — no builder, no stream — synchronous.

Passes the AP + SC cached policies; PAC picks the right one based on the key’s namespace mode (from the in-memory partition map).

Return type:

Optional[Record]

put(key, bins)[source]

Direct single-key upsert — no builder, no stream — synchronous.

Passes the AP + SC cached policies; PAC picks the right one based on the key’s namespace mode.

Return type:

None

truncate(dataset, before_nanos=None)[source]

Truncate a set, synchronously (PAC truncate_blocking).

Return type:

None

namespace_sc_status(namespace)[source]

Describe whether a namespace is SC; includes a reason when it is not.

Return type:

NamespaceScStatus

is_namespace_sc(namespace)[source]

True if namespace is in strong-consistency mode.

Return type:

bool

info(command=None)[source]
Overloads:
  • selfSyncInfoCommands

  • self, command (str) → Dict[str, str]

Sync info: return SyncInfoCommands or raw blocking result.

query(arg1=None, arg2=None, *keys, namespace=None, set_name=None, dataset=None, key=None, keys_list=None, behavior=None)[source]

Start a synchronous read or secondary-index query.

Same shapes as Session.query. Always returns SyncQueryBuilder whose execute() runs synchronously.

Return type:

SyncQueryBuilder

batch()[source]

Start a multi-key batch of mixed write operations (synchronous).

Return type:

SyncBatchOperationBuilder

background_task()[source]

Start a background dataset task chain (synchronous).

Return type:

SyncBackgroundTaskSession

execute_udf(*keys)[source]

Begin a foreground UDF invocation (synchronous).

Return type:

SyncUdfFunctionBuilder

index(namespace=None, set_name=None, *, dataset=None, behavior=None)[source]

Synchronous secondary-index builder.

Return type:

SyncIndexBuilder

transaction_session()[source]

Alias for begin_transaction().

Return type:

SyncTransactionalSession

begin_transaction()[source]

Start a multi-record transaction (synchronous).

Return type:

SyncTransactionalSession

do_in_transaction(operation, *, max_attempts=5, sleep_between_retries=0.0)[source]

Run a callable inside a retrying multi-record transaction (synchronous).

Return type:

Any

upsert(arg1=None, arg2=None, *keys, key=None, dataset=None, namespace=None, set_name=None, key_value=None)[source]

Create an upsert write segment (synchronous).

Return type:

SyncWriteSegmentBuilder

insert(arg1=None, arg2=None, *keys, key=None, dataset=None, namespace=None, set_name=None, key_value=None)[source]

Create an insert write segment (synchronous).

Return type:

SyncWriteSegmentBuilder

update(arg1=None, arg2=None, *keys, key=None, dataset=None, namespace=None, set_name=None, key_value=None)[source]

Create an update write segment (synchronous).

Return type:

SyncWriteSegmentBuilder

replace(arg1=None, arg2=None, *keys, key=None, dataset=None, namespace=None, set_name=None, key_value=None)[source]

Create a replace write segment (synchronous).

Return type:

SyncWriteSegmentBuilder

replace_if_exists(arg1=None, arg2=None, *keys, key=None, dataset=None, namespace=None, set_name=None, key_value=None)[source]

Create a replace-if-exists write segment (synchronous).

Return type:

SyncWriteSegmentBuilder

delete(arg1=None, arg2=None, *keys, key=None, dataset=None, namespace=None, set_name=None, key_value=None)[source]

Create a delete write segment (synchronous).

Return type:

SyncWriteSegmentBuilder

touch(arg1=None, arg2=None, *keys, key=None, dataset=None, namespace=None, set_name=None, key_value=None)[source]

Create a touch write segment (synchronous).

Return type:

SyncWriteSegmentBuilder

exists(arg1=None, arg2=None, *keys, key=None, dataset=None, namespace=None, set_name=None, key_value=None)[source]

Create an exists-check write segment (synchronous).

Return type:

SyncWriteSegmentBuilder