工作流程自動化 · API / SDK
Apache Software Foundation
串接資料工作流程排程器的公開接口。
APACHE AIRFLOW / DEVELOPER FIELD GUIDE
公司／專案背景、十個技術入口，以及每份引用的實作分析。
2026-10-08 · 串接尚未實測
依官方公司或專案自述撰寫的原創概要；完整原文請見來源。
| 專案 | Apache Airflow 是社群開發的流程撰寫、排程與監控平台。 |
|---|---|
| 程式模型 | Python Dag 定義描述工作相依；executors 與 providers 連接執行基礎設施。 |
| API 邊界 | 本指南依目前 Airflow 3 文件；調整舊 Airflow 2 整合前核對 API 版本及驗證。 |
| 適用角色 | 進行 AI 供應商初選的採購、合作夥伴與產品負責人。 |
|---|---|
| 本站評估 | 用定位與公司背景判斷初步適配度；另行取得專案部署、支援與商務條件。 |
已核對官方來源。未呼叫供應商 API 或執行推論；結果為內部契約示意。
依實作決策選出的十個技術文件入口，非十套獨立 SDK 或官方排名。
| 接口 | 用途與 TA |
|---|---|
| 01 · Public API authenticationAPI / SDK / developer guide | 驗證目前公開 API 呼叫。API 工程師 |
| 02 · DagsAPI / SDK / developer guide | 定義任務、相依與排程。流程作者 |
| 03 · TasksAPI / SDK / developer guide | 執行及追蹤離散工作單元。任務工程師 |
| 04 · Dag runs and data intervalsAPI / SDK / developer guide | 追蹤特定資料區間執行。排程工程師 |
| 05 · SchedulerAPI / SDK / developer guide | 排程符合條件任務實例。平台維運人員 |
| 06 · ExecutorAPI / SDK / developer guide | 選擇任務如何在可用資源執行。基礎設施團隊 |
| 07 · PoolsAPI / SDK / developer guide | 限制受限系統的任務並行度。資源負責人 |
| 08 · XComsAPI / SDK / developer guide | 傳遞任務資料參照或小值。管線工程師 |
| 09 · Connections and hooksAPI / SDK / developer guide | 設定外部系統存取。外部整合團隊 |
| 10 · Best practicesAPI / SDK / developer guide | 設計可重現且可安全重試的任務。正式環境維護者 |
能力摘要依據官方文件；限制與建議測試為本站工程評估。
API / SDK / developer guide
| 目標讀者 TA | API 工程師 |
|---|---|
| 官方文件能力 | 驗證目前公開 API 呼叫。 |
| 輸入 → 輸出 | 有效 bearer token 與請求 → 獲授權回應。 |
| 執行環境 | 已設定 Airflow 3 部署、scheduler、executor 與相關 providers |
| 本站選型評估 | Airflow 3 API 與設定 auth manager 不同於旧部署。 |
| 本站建議驗證 | 檢查部署 API 綱要、token 到期與存取遭拒。 |
API / SDK / developer guide
| 目標讀者 TA | 流程作者 |
|---|---|
| 官方文件能力 | 定義任務、相依與排程。 |
| 輸入 → 輸出 | Python Dag 定義 → 可發現流程。 |
| 執行環境 | 已設定 Airflow 3 部署、scheduler、executor 與相關 providers |
| 本站選型評估 | 解析與匯入失敗會阻止發現。 |
| 本站建議驗證 | 驗證 Dag 發現與預期相依圖。 |
API / SDK / developer guide
| 目標讀者 TA | 任務工程師 |
|---|---|
| 官方文件能力 | 執行及追蹤離散工作單元。 |
| 輸入 → 輸出 | 任務輸入與相依狀態 → 任務狀態／結果。 |
| 執行環境 | 已設定 Airflow 3 部署、scheduler、executor 與相關 providers |
| 本站選型評估 | Skipped 與 upstream-failed 不同於成功工作。 |
| 本站建議驗證 | 測試重試、逾時與相依結果。 |
API / SDK / developer guide
| 目標讀者 TA | 排程工程師 |
|---|---|
| 官方文件能力 | 追蹤特定資料區間執行。 |
| 輸入 → 輸出 | 觸發或排程 → Dag run。 |
| 執行環境 | 已設定 Airflow 3 部署、scheduler、executor 與相關 providers |
| 本站選型評估 | 邏輯日期非實際執行時間；葉節點規則影響執行成功狀態。 |
| 本站建議驗證 | 驗證必要任務與輸出區間，不只最上層成功狀態。 |
API / SDK / developer guide
| 目標讀者 TA | 平台維運人員 |
|---|---|
| 官方文件能力 | 排程符合條件任務實例。 |
| 輸入 → 輸出 | Dag／執行狀態 → 已排程任務。 |
| 執行環境 | 已設定 Airflow 3 部署、scheduler、executor 與相關 providers |
| 本站選型評估 | 排程器健康不代表 executor 容量充足。 |
| 本站建議驗證 | 追蹤排程延遲與停滯執行。 |
API / SDK / developer guide
| 目標讀者 TA | 基礎設施團隊 |
|---|---|
| 官方文件能力 | 選擇任務如何在可用資源執行。 |
| 輸入 → 輸出 | 佇列任務 → 執行後端。 |
| 執行環境 | 已設定 Airflow 3 部署、scheduler、executor 與相關 providers |
| 本站選型評估 | Executor 與 provider 相依項目依部署而異。 |
| 本站建議驗證 | 測試容量、相依可用性與 worker 遺失。 |
API / SDK / developer guide
| 目標讀者 TA | 資源負責人 |
|---|---|
| 官方文件能力 | 限制受限系統的任務並行度。 |
| 輸入 → 輸出 | Pool slots 與佇列任務 → 允許並行度。 |
| 執行環境 | 已設定 Airflow 3 部署、scheduler、executor 與相關 providers |
| 本站選型評估 | Slot 耗盡應使工作排隊，不代表失敗。 |
| 本站建議驗證 | 突發負載與任務完成時驗證 slots。 |
API / SDK / developer guide
| 目標讀者 TA | 管線工程師 |
|---|---|
| 官方文件能力 | 傳遞任務資料參照或小值。 |
| 輸入 → 輸出 | 任務產生值 → 下游值。 |
| 執行環境 | 已設定 Airflow 3 部署、scheduler、executor 與相關 providers |
| 本站選型評估 | 大型酬載需要適當後端儲存策略。 |
| 本站建議驗證 | 檢查序列化與缺失上游值。 |
API / SDK / developer guide
| 目標讀者 TA | 外部整合團隊 |
|---|---|
| 官方文件能力 | 設定外部系統存取。 |
| 輸入 → 輸出 | Connection 參照 → provider 特定用戶端存取。 |
| 執行環境 | 已設定 Airflow 3 部署、scheduler、executor 與相關 providers |
| 本站選型評估 | Provider 套件與憑證須符合目標服務。 |
| 本站建議驗證 | 測試連線可用性，不記錄秘密。 |
API / SDK / developer guide
| 目標讀者 TA | 正式環境維護者 |
|---|---|
| 官方文件能力 | 設計可重現且可安全重試的任務。 |
| 輸入 → 輸出 | Dag／任務設計 → 可維護執行行為。 |
| 執行環境 | 已設定 Airflow 3 部署、scheduler、executor 與相關 providers |
| 本站選型評估 | 若任務未設計重試處理，可能重複寫入。 |
| 本站建議驗證 | 測試冪等與歷史區間重跑。 |
| TA | 工程師與技術產品負責人 |
|---|---|
| 本站驗證建議 | 實作前固定版本並依目標環境核對支援條件。 |
04 / INPUT · EXPECTED OUTPUT · ACCEPTANCE
批次資料流程示意契約，非 Airflow REST 原始回應。未觸發 Dag 或執行任務。
示意契約 · 未呼叫 API 或執行模型 · 不是供應商實測輸出
| 輸入 | 指定輸入區間的有效 Dag 觸發。 |
|---|---|
| 預期結果 | 必要任務與目的紀錄檢查後 ok。 |
| 驗收條件 | 不可只依葉節點推導的 Dag 成功狀態。 |
| 輸入 | 授權來源查詢在該區間無資料。 |
|---|---|
| 預期結果 | 成功無操作，零筆紀錄與區間識別。 |
| 驗收條件 | 區分合法零筆與來源驗證失敗。 |
| 輸入 | 可執行任務等待設定 pool slots。 |
|---|---|
| 預期結果 | queued／pending，不宣稱已處理資料。 |
| 驗收條件 | 檢查 pool 可用性與排程延遲。 |
| 輸入 | 必要擷取任務重試後失敗。 |
|---|---|
| 預期結果 | 受影響任務為 failed 或 upstream_failed；不宣稱業務成功。 |
| 驗收條件 | 核對部分寫入並冪等重跑同區間。 |
將實際執行環境回應對應至此建議應用契約。所有數值皆為示意，不含憑證或真實執行。
{
"schema_version": "1.0.0",
"example": true,
"provider": "Apache Airflow",
"status": "ok",
"input_id": "sample-001",
"data": {
"dag_id": "example-daily-import",
"dag_run_id": "example-run",
"dag_state": "success",
"required_tasks_verified": true,
"records_written": 12
},
"error": null,
"verification": "illustrative-only;not-provider-response"
}| 狀態語意 | 有效空結果與錯誤不同；等待中的工作不可提前顯示成功。 |
|---|---|
| 證據 | 記錄服務與 SDK 版本、請求識別、設定及回應映射。此處未執行或量測效能。 |
| 建議驗收 | 以授權代表樣本測試前，先約定數值誤差與負載目標。 |
開發評估
開發構想規格・串接尚未實測
接口能力依據官方文件或程式庫；以下產品方向、輸入、交付與驗收條件則是我們的開發評估。
估算可交付產品前，需共同驗證執行環境、資料結構或硬體。
記錄產品瀏覽、官方文件點擊、規格下載與技術 Hub 點擊。這些是事件次數，不等於獨立人數或已完成串接。
本次可行性評估依實作條件判斷；尚未給定流量排名或交期承諾。