имеют DAG Airflow, определенные в файле python. Хотелось бы выполнить запрос к общедоступным данным из больших запросов, локализованным в США, и сохранить результат в моей биографии в ЕС. Было бы здорово управлять операцией за один шаг группы обеспечения доступности баз данных.
Используйте код, подобный приведенному ниже, но он выдает ошибку: задайте местоположение для US, но выходной набор данных находится в другом месте.
get_data = bigquery_operator.BigQueryOperator(
...
location='US',
sql="""
select ...
from 'bigquery-public-data.new_tork_taxi_trips.tlc_green_trips_2018'''
""",
destination_dataset_table=<my-proj>.<my-dataset>.<my-table>,
...
)