iter_query `async` ¶

iter_query(
    query_string: QueryString,
    *,
    config_overrides: Optional[AsyncTimestreamQueryClientConfig] = None,
    client_token: Optional[ClientRequestToken] = None,
    next_token: Optional[PaginationToken] = None,
    max_rows: Optional[MaxQueryResults] = None,
    query_insights: Optional[QueryInsights] = None,
) -> AsyncIterator[Row]

Source code in docs_src/capo_timestream_query/_services/async_timestream_query.py

async def iter_query(
    self,
    query_string: "capo_timestream_query.types.query_string.QueryString",
    *,
    config_overrides: Optional[AsyncTimestreamQueryClientConfig] = None,
    client_token: Optional[
        "capo_timestream_query.types.client_request_token.ClientRequestToken"
    ] = None,
    next_token: Optional[
        "capo_timestream_query.types.pagination_token.PaginationToken"
    ] = None,
    max_rows: Optional[
        "capo_timestream_query.types.max_query_results.MaxQueryResults"
    ] = None,
    query_insights: Optional[
        "capo_timestream_query.types.query_insights.QueryInsights"
    ] = None,
) -> "AsyncIterator[capo_timestream_query.types.row.Row]":
    _token = next_token
    while True:
        _response = await self.query(
            query_string,
            config_overrides=config_overrides,
            client_token=client_token,
            next_token=_token,
            max_rows=max_rows,
            query_insights=query_insights,
        )
        _page = _resolve_path(_response, ("rows",))
        for _item in _page or []:
            yield _item
        _token = _resolve_path(_response, ("next_token",))
        if not _token:
            break

iter_query async ¶

iter_query `async` ¶