如何解决如何使用 apache 气流调度谷歌云 bigquery 存储过程
我想在 apache 气流中安排一个谷歌云 bigquery 存储过程。我没有在气流中看到任何文档。我应该使用哪个调度程序来调度 apache 气流上的 bigquery 存储过程。你能给我看一些例子吗?非常感谢。
解决方法
BigQueryInsertJobOperator 应该是 DAG 中用于在 BigQuery 中执行 SQL 的运算符——这是您调用存储过程时执行的操作。
例如:
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,)
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。