社群
線下聚會
文件
使用案例
公告
部落格
生態系統
社群
線下聚會
文件
使用案例
公告
部落格
生態系統
內容
版本:
2.10.4
內容
概觀
快速開始
Airflow® 安裝
安全性
教學
操作指南
UI / 螢幕截圖
核心概念
撰寫與排程
外掛程式
可延遲運算子 & 觸發器
DAG 檔案處理
序列化
連線 & Hooks
動態任務映射
Cron & 時間間隔
時區
資料感知排程
時程表
管理與部署
整合
Airflow 的公開介面
最佳實務
常見問題
疑難排解
發布政策
發布說明
隱私權聲明
專案
許可證
參考資料
運算子與 hooks
CLI
範本
穩定 REST API
已棄用的 REST API
組態
額外套件
內部資料庫詳細資訊
資料庫遷移
資料庫 ERD 結構描述
系統測試
系統測試
版本:
2.10.4
內容
概觀
快速開始
Airflow® 安裝
安全性
教學
操作指南
UI / 螢幕截圖
核心概念
撰寫與排程
外掛程式
可延遲運算子 & 觸發器
DAG 檔案處理
序列化
連線 & Hooks
動態任務映射
Cron & 時間間隔
時區
資料感知排程
時程表
管理與部署
整合
Airflow 的公開介面
最佳實務
常見問題
疑難排解
發布政策
發布說明
隱私權聲明
專案
許可證
參考資料
運算子與 hooks
CLI
範本
穩定 REST API
已棄用的 REST API
組態
額外套件
內部資料庫詳細資訊
資料庫遷移
資料庫 ERD 結構描述
系統測試
系統測試
首頁
撰寫與排程
撰寫與排程
¶
您可以在此找到關於進階撰寫和排程 Airflow DAG 的詳細文件。建議您先查看
核心概念
中的頁面
撰寫
外掛程式
為了什麼?
為什麼要在 Airflow 之上構建?
外掛程式何時(重新)載入?
介面
範例
從 CSRF 保護中排除視圖
外掛程式作為 Python 套件
自動重新載入網路伺服器
疑難排解
可延遲運算子 & 觸發器
使用可延遲運算子
撰寫可延遲運算子
高可用性
感測器中 Mode=’reschedule’ 和 Deferrable=True 之間的差異
DAG 檔案處理
序列化
Airflow 物件
連線 & Hooks
Hooks
自訂連線
動態任務映射
簡單映射
使用非 TaskFlow 運算子進行映射
將多個參數分配給非 TaskFlow 運算子
映射到任務群組
從映射任務中篩選項目
轉換擴展資料
合併上游資料(又稱“壓縮”)
串連多個上游
哪些資料類型可以擴展?
範本化欄位和映射引數如何互動?
對映射任務設定限制
自動跳過零長度映射
排程
Cron & 時間間隔
Cron 預設值
時區
Web UI
概念
時區感知 DAG
資料感知排程
快速入門
什麼是“資料集”?
什麼是有效的 URI?
關於資料集的額外資訊
如何在您的 DAG 中使用資料集
多個資料集
將額外資訊附加到發射資料集事件
從先前發射的資料集事件中獲取資訊
從觸發資料集事件中獲取資訊
透過 REST API 操作佇列的資料集事件
使用條件表達式進行進階資料集排程
範例用法
透過 DatasetAlias 動態資料事件發射和資料集建立
結合資料集和基於時間的排程
時程表
內建時程表
時程表比較
上一頁
下一頁
此條目是否有幫助?
撰寫與排程
建議在此頁面上進行變更