Airflow 2025 峰會將於 10 月 07-09 日舉行。立即註冊獲取早鳥票!

變數

變數是 Airflow 的執行時配置概念 - 一個全域性的通用鍵/值儲存,可以從任務中查詢,並且可以透過 Airflow 的使用者介面輕鬆設定,或者作為 JSON 檔案批次上傳。

要使用它們,只需匯入 Variable 模型並呼叫 get 方法

from airflow.sdk import Variable

# Normal call style
foo = Variable.get("foo")

# Auto-deserializes a JSON value
bar = Variable.get("bar", deserialize_json=True)

# Returns the value of default (None) if the variable is not set
baz = Variable.get("baz", default=None)

您也可以在模板中使用它們

# Raw value
echo {{ var.value.<variable_name> }}

# Auto-deserialize JSON value
echo {{ var.json.<variable_name> }}

變數是**全域性的**,應僅用於覆蓋整個安裝的總體配置;要將資料從一個任務/Operator 傳遞到另一個,應改用XComs

我們還建議您儘量將大多數設定和配置儲存在 DAG 檔案中,以便可以使用原始碼控制進行版本控制;變數確實只用於真正依賴於執行時的值。

有關設定和管理變數的更多資訊,請參閱管理變數

本條目有幫助嗎?