直观体验基于 Asset 的调度
前面练习中的 sales_producer 和 sales_consumer 两个 Dag 已加载到 Airflow UI。生产者会写入销售数据，并更新 s3://data-lake/sales/daily.csv 这个 Asset。消费者则在该 Asset 上进行调度。
请按以下步骤操作：
- 在 Dags 视图中找到
sales_producer和sales_consumer，用切换开关将它们激活。 - 点击播放图标触发
sales_producer，选择 Single Run，然后点击 Trigger。 - 等待生产者运行完成（所有任务变为绿色）。
- 检查
sales_consumer是否在您未手动点击的情况下被自动触发。
当 sales_producer 运行完成后，sales_consumer 会发生什么？
本练习是课程的一部分
