How can you create a view using the BigQueryOperator in airflow?

Question

From GCP docs: https://cloud.google.com/bigquery/docs/views their instructions for creating a view using the BQ API is "Call the tables.insert method with a table resource that contains a view property."

Any idea how to do this via airflow's BigQueryOperator? Or is there another operator I should us?

Mikhail Berlyant Mikhail Berlyant · Accepted Answer · 2019-12-17T23:12:08

Just use DDL's CREATE VIEW statement as

{CREATE VIEW | CREATE VIEW IF NOT EXISTS | CREATE OR REPLACE VIEW}
view_name
[OPTIONS(view_option_list)]
AS query_expression

How can you create a view using the BigQueryOperator in airflow?

2 Answers