Class AsyncAggregationQuery (2.19.0)

AsyncAggregationQuery(nested_query)

Represents an aggregation query to the Firestore API.

Methods

get

get(
    transaction=None,
    retry: Union[
        retries.AsyncRetry, None, gapic_v1.method._MethodDefault
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: float | None = None,
    *,
    explain_options: Optional[ExplainOptions] = None
) -> QueryResultsList[List[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
`QueryResultsList[List[AggregationResult]]`	The aggregation query results.

stream

stream(
    transaction: Optional[transaction.Transaction] = None,
    retry: Optional[retries.AsyncRetry] = _MethodDefault._DEFAULT_VALUE,
    timeout: Optional[float] = None,
    *,
    explain_options: Optional[ExplainOptions] = None
) -> AsyncStreamGenerator[List[AggregationResult]]

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
`AsyncStreamGenerator[List[AggregationResult]]`	A generator of the query results.