使用 BashOperator 运行 BigQuery bq 命令

使用 Apache Airflow DAG 中的 BashOperator 调用 BigQuery bq 命令。

深入探索

如需查看包含此代码示例的详细文档，请参阅以下内容：

• 编写 DAG（工作流）

代码示例

Python

在 GitHub 上查看 反馈

from airflow.operators import bash
    # Create BigQuery output dataset.
    make_bq_dataset = bash.BashOperator(
        task_id='make_bq_dataset',
        # Executing 'bq' command requires Google Cloud SDK which comes
        # preinstalled in Cloud Composer.
        bash_command=f'bq ls {bq_dataset_name} || bq mk {bq_dataset_name}')

后续步骤

如需搜索和过滤其他 Google Cloud 产品的代码示例，请参阅 Google Cloud 示例浏览器。