ExecuteQueryIteratorAsync(
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]] = (),
)
Collects responses from ExecuteQuery requests and parses them into QueryResultRows.
It is not thread-safe. It should not be used by multiple asyncio Tasks.
Properties
app_profile_id
Returns the app_profile_id of the iterator.
is_closed
Returns True if the iterator is closed, False otherwise.
table_name
Returns the table_name of the iterator.
Methods
close
close() -> None
Cancel all background tasks. Should be called all rows were processed.
metadata
metadata() -> (
typing.Optional[google.cloud.bigtable.data.execute_query.metadata.Metadata]
)
Returns query metadata from the server or None if the iterator was explicitly closed.