Есть ли чтения или аналогично в BigQuery Storage Python API ⇐ Python

[Anonymous]

Мой (рабочий) код примерно делает следующее: < /p>

Код: Выделить всё

    read_session = bigquery_storage.ReadSession(...)
request = bigquery_storage.CreateReadSessionRequest(...)
session = client.create_read_session(request=request)
iterator = [client.read_rows(stream.name).rows(session) for stream in session.streams][0]
# and here I can nicely iterate over the rows...

Однако я ненавижу код, который он блокирует. Чтение без каких -либо асинхронных методов. < /P>
Я что -то упускаю? Есть ли хороший, асинхровый способ лениво итерации над рядами таблицы / запроса BigQuery с каким -то асинхронным буфером? Кажется достаточно стандартным вариантом использования, поэтому мне интересно, чего мне не хватает.

Подробнее здесь: https://stackoverflow.com/questions/796 ... python-api