airflow.example_dags.example_asset_alias¶
示例 DAG，用于演示 Airflow 中 AssetAlias 功能的行为，包括条件和基于资产表达式的调度。
使用说明
启用所有 DAG。
一旦触发“asset_s3_bucket_producer” DAG，则在完成时应触发“asset_s3_bucket_consumer” DAG。这是因为在“produce_asset_events_through_asset_alias”任务期间，使用资产别名“example-alias”为资产“s3://bucket/my-task”添加了一个资产事件。由于 DAG “asset-alias-consumer”依赖于之前未解析的资产别名“example-alias”，因此 DAG “asset-alias-consumer”（以及同一文件中的所有 DAG）将被重新解析，从而将其调度更新为资产“s3://bucket/my-task”，并且也将被触发。
函数¶
|
|
|