AsyncCluster Overloads

AsyncCluster

Important

Not all class methods are listed. Only methods that allow overloads.

class acouchbase_columnar.cluster.AsyncCluster

execute_query(statement: str) → Future[AsyncQueryResult]

execute_query(statement: str, options: QueryOptions) → Future[AsyncQueryResult]

execute_query(statement: str, **kwargs: QueryOptionsKwargs) → Future[AsyncQueryResult]

execute_query(statement: str, options: QueryOptions, **kwargs: QueryOptionsKwargs) → BlockingQueryResult

execute_query(statement: str, options: QueryOptions, *args: JSONType, **kwargs: QueryOptionsKwargs) → Future[AsyncQueryResult]

execute_query(statement: str, options: QueryOptions, *args: JSONType, **kwargs: str) → Future[AsyncQueryResult]

execute_query(statement: str, *args: JSONType, **kwargs: str) → Future[AsyncQueryResult]

Executes a query against a Capella Columnar cluster.

Important

The cancel API is VOLATILE and is subject to change at any time.

Parameters:

statement (str) – The SQL++ statement to execute.
options (Optional[QueryOptions]) – Options to set for the query.
*args (Optional[JSONType]) – Can be used to pass in positional query placeholders.
**kwargs (Optional[Union[QueryOptionsKwargs, str]]) – Keyword arguments that can be used in place or to overrride provided ClusterOptions. Can also be used to pass in named query placeholders.

Returns:

A Future is returned. Once the Future completes, an instance of a AsyncQueryResult will be available.

Return type:

Future[AsyncQueryResult]

classmethod create_instance(connstr: str, credential: Credential) → AsyncCluster

classmethod create_instance(connstr: str, credential: Credential, loop: AbstractEventLoop) → AsyncCluster

classmethod create_instance(connstr: str, credential: Credential, options: ClusterOptions) → AsyncCluster

classmethod create_instance(connstr: str, credential: Credential, options: ClusterOptions, loop: AbstractEventLoop) → AsyncCluster

classmethod create_instance(connstr: str, credential: Credential, **kwargs: ClusterOptionsKwargs) → AsyncCluster

classmethod create_instance(connstr: str, credential: Credential, loop: AbstractEventLoop, **kwargs: ClusterOptionsKwargs) → AsyncCluster

classmethod create_instance(connstr: str, credential: Credential, options: ClusterOptions, **kwargs: ClusterOptionsKwargs) → AsyncCluster

classmethod create_instance(connstr: str, credential: Credential, options: ClusterOptions, loop: AbstractEventLoop, **kwargs: ClusterOptionsKwargs) → AsyncCluster

Create a Cluster instance

Parameters:

connstr (str) – The connection string to use for connecting to the cluster. The format of the connection string is the scheme (couchbases as TLS enabled connections are _required_), followed a hostname
credential (Credential) – The user credentials.
loop (AbstractEventLoop) – The asyncio event loop.
options (Optional[ClusterOptions]) – Global options to set for the cluster. Some operations allow the global options to be overriden by passing in options to the operation.
**kwargs (Optional[ClusterOptionsKwargs]) – Keyword arguments that can be used in place or to overrride provided ClusterOptions

Returns:

A Capella Columnar AsyncCluster instance.

Return type:

AsyncCluster

Raises: