ZhangZhihui's Blog  

2025年12月15日

摘要: In shell (especially POSIX shells like sh, bash, dash, zsh), : is a builtin command called the null command. What it does Does nothing Always succeeds 阅读全文
posted @ 2025-12-15 23:29 ZhangZhihuiAAA 阅读(0) 评论(0) 推荐(0)
 
摘要: """ Example DAG for demonstrating the usage of event driven scheduling using assets and triggers. """ from __future__ import annotations from airflow. 阅读全文
posted @ 2025-12-15 22:30 ZhangZhihuiAAA 阅读(3) 评论(0) 推荐(0)
 
摘要: dag1_asset = Asset('s3://dag1/output_1.txt', extra={"hi": "bye"}) In Airflow, the extra parameter on an Asset is free-form metadata you can attach to 阅读全文
posted @ 2025-12-15 20:46 ZhangZhihuiAAA 阅读(2) 评论(0) 推荐(0)
 
摘要: In Airflow, AssetAlias is a way to define a logical alias (group name) for one or more assets, so that producers and consumers can be loosely coupled 阅读全文
posted @ 2025-12-15 17:48 ZhangZhihuiAAA 阅读(1) 评论(0) 推荐(0)
 
摘要: In Apache Airflow, an asset is a logical representation of a piece of data that your workflows produce or consume, independent of where that data live 阅读全文
posted @ 2025-12-15 15:56 ZhangZhihuiAAA 阅读(1) 评论(0) 推荐(0)
 
摘要: from __future__ import annotations import logging from datetime import datetime from airflow.sdk import dag, task log = logging.getLogger(__name__) @d 阅读全文
posted @ 2025-12-15 11:11 ZhangZhihuiAAA 阅读(1) 评论(0) 推荐(0)
 
摘要: from __future__ import annotations import logging from datetime import datetime from airflow.sdk import dag, task log = logging.getLogger(__name__) @d 阅读全文
posted @ 2025-12-15 10:27 ZhangZhihuiAAA 阅读(4) 评论(0) 推荐(0)

2025年12月12日

摘要: ✅ 1. Operators (Classic style) Tasks are created explicitly using Operator classes like BashOperator, PythonOperator, ShortCircuitOperator, etc. Examp 阅读全文
posted @ 2025-12-12 21:48 ZhangZhihuiAAA 阅读(5) 评论(0) 推荐(0)
 
摘要: """ Example DAG demonstrating the EmptyOperator and a custom EmptySkipOperator which skips by default. """ from __future__ import annotations import d 阅读全文
posted @ 2025-12-12 21:12 ZhangZhihuiAAA 阅读(3) 评论(0) 推荐(0)
 
摘要: """Example DAG demonstrating the usage of the ShortCircuitOperator.""" from __future__ import annotations import pendulum from airflow.providers.stand 阅读全文
posted @ 2025-12-12 20:28 ZhangZhihuiAAA 阅读(1) 评论(0) 推荐(0)