Assetに基づくコンシューマーDagのスケジューリング

売上データのプロデューサーがデータの準備完了を通知するようになりました。次に、Assetが更新されるたびに自動的に実行されるコンシューマーDagを作成しましょう。同じAsset（s3://data-lake/sales/daily.csv）を定義し、コンシューマーのスケジュールにそのAssetを設定することで、更新のたびにAirflowがDagを自動的にトリガーします。