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 のサンプルをご覧ください。