Для потока данных требуется разрешение bigquery.datasets.get для базовой таблицы в авторизованном представлении

Question

В конвейере потока данных я читаю из авторизованного представления BigQuery:

beam.io.Read (beam.io.BigQuerySource (query = "SELECT col1 FROM proj2.dataset2.auth_view1", use_standard_sql = True))

Это ошибка, которую я получаю:

Ошибка: Сообщение: доступ запрещен: набор данных proj1: набор данных1: пользователь xxxxxx-compute@developer.gserviceaccount.com не имеет разрешения bigquery.datasets.get для набора данных proj1: набор данных1.

proj1: набор данных1 имеет базовую таблицу для представления auth_view1.

Согласно этой проблеме в DataflowJavaSDK, поток данных, по-видимому, напрямую выполняет какой-то запрос метаданных к базовой таблице.

Есть ли исправление для этой проблемы в Apache Beam SDK?

Answer 1

Явная установка местоположения запроса также является решением в Apache Beam Java SDK с использованием опции withQueryLocation BigQueryIO .

Похоже, что установка местоположения запроса невозможна в Python SDK .