XCom を使ったデータの受け渡し
ETL ワークフローを更新し、XCom を使って情報をより簡単に管理できるようにしています。そのために、Dag 内のタスク間の依存関係を更新する必要があります。
以下のように使用できる 4 つのタスクがすでに定義されています。
extract()-order_dataを返しますtransform(order_data)- 集計データを返しますload(summary_data)- XCom 情報を返しませんsend_report()- 通知を処理する非 XCom タスクです
この演習はコースの一部です
Python で学ぶ Apache Airflow 入門
演習の手順
extract()とload()の間にtransformタスクを挿入して、チェーンを完成させましょう。- 結果を
etl_resultという名前の変数に代入しましょう。 etl_result変数の後にsend_reportが実行されるよう設定しましょう。
実践的なインタラクティブ演習
このサンプルコードを完成させて、この演習に挑戦してみましょう。
@dag(start_date=datetime(2026,4,1))
def etl_example():
# Chain extract, transform, and load, assigning the result
____ = load(____(extract()))
# Run send_report after the ETL tasks
etl_result ____ ____()
etl_example()