5

BigQueryOperatorGoogle Cloud Composer の Airflow DAG で広範囲に使用しています。

.sqlより長いクエリの場合は、DAG を乱雑にするよりも、各クエリを独自のファイルに配置することをお勧めします。ドキュメントでわかるように、Airflow は BigQueryOperator を含むすべての SQL クエリ演算子でこれをサポートしているようです。

私の質問:.sqlテンプレート ファイルに my sql ステートメントを記述した後、それを Google Cloud Composer に追加して DAG で参照するにはどうすればよいですか?

4

3 に答える 3