アセットベースのスケジューリングを実際に確認する
前の演習で作成した sales_producer と sales_consumer の両 DAG が Airflow UI に読み込まれています。プロデューサーは売上データを書き込み、s3://data-lake/sales/daily.csv アセットを更新します。コンシューマーはそのアセットをスケジュールの基準としています。
次の手順に従いましょう。
- DAG ビューで
sales_producerとsales_consumerの両方を見つけ、トグルスイッチを使ってそれぞれを有効にします。 - 再生アイコンをクリックして
sales_producerをトリガーし、Single Run を選択してから Trigger をクリックします。 - プロデューサーの実行が完了するまで待ちます（すべてのタスクが緑色になった状態）。
- 自分で何もクリックしなくても
sales_consumerが自動的にトリガーされたかどうかを確認します。
sales_producer の実行が完了した後、sales_consumer はどうなりますか？
この演習はコースの一部です
