カスタム Airflow 接続の使用

以前に作成したカスタム Airflow 接続を使用してタスクを実行します。

もっと見る

このコードサンプルを含む詳細なドキュメントについては、以下をご覧ください。

• Airflow 接続の管理

コードサンプル

Python

GitHub で表示 フィードバック

# Set a gcp_conn_id to use a connection that you have created.
task_custom = bigquery.BigQueryInsertJobOperator(
    task_id='task_custom_connection',
    gcp_conn_id='my_gcp_connection',
    configuration={
        "query": {
            "query": 'SELECT 1',
            "useLegacySql": False
        }
    }
)

次のステップ

他の Google Cloud プロダクトに関連するコードサンプルの検索およびフィルタ検索を行うには、Google Cloud のサンプルをご覧ください。