Выполнение запроса Google для запросов Google с использованием потока данных Google Cloud

Question

Возможно ли выполнить запрос Bigquery с использованием потока данных Google cloud напрямую и получить данные, а не считывать данные из таблицы, а затем устанавливать условия?

Например, PCollections Рез = p.apply (BigqueryIO.execute ("Выберите col1, col2 из publicdata: samples.shakeseare где ...."))

Вместо того чтобы изобретать, используя итерационный метод, какой BigQuery запросы уже реализованные, мы можем использовать их напрямую.

Спасибо и наилучшими пожеланиями

Аджай K N

Answer 1

BigQueryIO в настоящее время поддерживает только чтение из таблицы, а не запрос или View (FAQ).

Один из способов обойти это в вашей основной программе, чтобы создать BigQuery permanent table, отправив запрос перед запуском задания Dataflow. После запуска вашей работы вы можете удалить таблицу.