Execute Query Iterator

class google.cloud.bigtable.data.execute_query.ExecuteQueryIterator(client: DataClientType, instance_id: str, app_profile_id: Optional[str], request_body: Dict[str, Any], attempt_timeout: float | None, operation_timeout: float, req_metadata: Sequence[Tuple[str, str]] = (), retryable_excs: Sequence[type[Exception]] = ())

Bases: object

Collects responses from ExecuteQuery requests and parses them into QueryResultRows.

It is not thread-safe. It should not be used by multiple threads.

  • Parameters

    • client – bigtable client

    • instance_id – id of the instance on which the query is executed

    • request_body – dict representing the body of the ExecuteQueryRequest

    • attempt_timeout – the time budget for an individual network request, in seconds. If it takes longer than this time to complete, the request will be cancelled with a DeadlineExceeded exception, and a retry will be attempted.

    • operation_timeout – the time budget for the entire operation, in seconds. Failed requests will be retried within the budget

    • req_metadata – metadata used while sending the gRPC request

    • retryable_excs – a list of errors that will be retried if encountered.

  • Raises

    None

property app_profile_id(: Optional[str )

Returns the app_profile_id of the iterator.

close()

Cancel all background tasks. Should be called all rows were processed.

property is_closed(: [bool](https://python.readthedocs.io/en/latest/library/functions.html#bool )

Returns True if the iterator is closed, False otherwise.

metadata()

Returns query metadata from the server or None if the iterator was explicitly closed.

property table_name(: Optional[str )

Returns the table_name of the iterator.