AggregationQuery(nested_query)
Represents an aggregation query to the Firestore API.
Methods
get
get(
transaction=None,
retry: typing.Union[
google.api_core.retry.Retry,
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=None,
retry: typing.Union[
google.api_core.retry.Retry,
None,
google.api_core.gapic_v1.method._MethodDefault,
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Optional[float] = None,
) -> typing.Generator[
typing.List[google.cloud.firestore_v1.base_aggregation.AggregationResult],
typing.Any,
None,
]
Runs the aggregation query.
This sends a RunAggregationQuery
RPC and then returns an iterator 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 |
retry |
google.api_core.retry.Retry
Designation of what errors, if any, should be retried. Defaults to a system-specified policy. |
timeout |
float :Yields: AggregationResult -- The result of aggregations of this query
The timeout for this request. Defaults to a system-specified value. |