SyncSession¶
- class aerospike_sdk.sync.session.SyncSession[source]¶
Bases:
objectRun 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 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:
- truncate(dataset, before_nanos=None)[source]¶
Truncate a set, synchronously (PAC
truncate_blocking).- Return type:
- namespace_sc_status(namespace)[source]¶
Describe whether a namespace is SC; includes a reason when it is not.
- Return type:
NamespaceScStatus
- info(command=None)[source]¶
- Overloads:
self → SyncInfoCommands
self, command (str) → Dict[str, str]
Sync info: return
SyncInfoCommandsor 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 returnsSyncQueryBuilderwhoseexecute()runs synchronously.- Return type:
- index(namespace=None, set_name=None, *, dataset=None, behavior=None)[source]¶
Synchronous secondary-index builder.
- Return type:
- transaction_session()[source]¶
Alias for
begin_transaction().- Return type:
- 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:
- 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:
- 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:
- 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:
- 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:
- 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:
- 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:
- 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: