AsyncAggregationQuery(nested_query)
Represents an aggregation query to the Firestore API.
Methods
get
get(
transaction=None,
retry: typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
None,
google.api_core.gapic_v1.method._MethodDefault,
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Optional[float] = None,
) -> typing.List[google.cloud.firestore_v1.base_aggregation.AggregationResult]
Runs the aggregation query.
This sends a RunAggregationQuery
RPC and returns a list of aggregation results in the stream of RunAggregationQueryResponse
messages.
Parameters | |
---|---|
Name | Description |
retry |
google.api_core.retry.Retry
Designation of what errors, if any, should be retried. Defaults to a system-specified policy. |
timeout |
float
The timeout for this request. Defaults to a system-specified value. |
Returns | |
---|---|
Type | Description |
list |
The aggregation query results |
stream
stream(
transaction: Optional[transaction.Transaction] = None,
retry: Optional[retries.AsyncRetry] = _MethodDefault._DEFAULT_VALUE,
timeout: Optional[float] = None,
) -> AsyncStreamGenerator[DocumentSnapshot]
Runs the aggregation query.
This sends a RunAggregationQuery
RPC and then returns a generator
which consumes each document returned in the stream of
RunAggregationQueryResponse
messages.
If a transaction
is used and it already has write operations added,
this method cannot be used (i.e. read-after-write is not allowed).
Parameters | |
---|---|
Name | Description |
transaction |
Optional[ Transaction]
An existing transaction that the query will run in. |
retry |
Optional[google.api_core.retry.Retry]
Designation of what errors, if any, should be retried. Defaults to a system-specified policy. |
timeout |
Optional[float]
The timeout for this request. Defaults to a system-specified value. |
Returns | |
---|---|
Type | Description |
|
A generator of the query results. |