如何使用 apache airflow schedule google 云 bigquery 存储过程
how to use apache airflow schedule google cloud bigquery stored procedure
我想在 apache airflow 中安排一个 google 云 bigquery 存储过程。我没有在气流中看到任何文档。我应该使用哪个调度程序来安排 apache 气流上的 bigquery 存储过程。你能给我举个例子吗?非常感谢。
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 中安排一个 google 云 bigquery 存储过程。我没有在气流中看到任何文档。我应该使用哪个调度程序来安排 apache 气流上的 bigquery 存储过程。你能给我举个例子吗?非常感谢。
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,
)