如何使用 apache airflow schedule google 云 bigquery 存储过程

Question

我想在 apache airflow 中安排一个 google 云 bigquery 存储过程。我没有在气流中看到任何文档。我应该使用哪个调度程序来安排 apache 气流上的 bigquery 存储过程。你能给我举个例子吗？非常感谢。

https://airflow.apache.org/docs/apache-airflow-providers-google/stable/operators/cloud/bigquery.html#execute-bigquery-jobs

Answer 1

BigQueryInsertJobOperator 应该是在 DAG 中用于执行 SQL 的运算符——这是您在 BigQuery 中调用存储过程时要执行的操作。

例如：

call_stored_procedure = BigQueryInsertJobOperator(
    task_id="call_stored_procedure",
    configuration={
        "query": {
            "query": "CALL `project_id.dataset.stored_procedure_name`(arg1, arg2); ",
            "useLegacySql": False,
        }
    },
    location=location,
)

如何使用 apache airflow schedule google 云 bigquery 存储过程

how to use apache airflow schedule google cloud bigquery stored procedure

google-bigquery

google-cloud-composer

airflow