變數

變數是 Airflow 的執行時期組態概念 — 一個通用的鍵/值儲存區,它是全域的,可以從您的任務中查詢,並且可以透過 Airflow 的使用者介面輕鬆設定,或以 JSON 檔案大量上傳。

若要使用它們,只需匯入並在 Variable 模型上呼叫 get

from airflow.models 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_var (None) if the variable is not set
baz = Variable.get("baz", default_var=None)

您也可以從範本中使用它們

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

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

變數是全域的,應僅用於涵蓋整個安裝的整體組態;若要將資料從一個任務/運算子傳遞到另一個任務/運算子,您應該改用XComs

我們也建議您盡可能將大多數設定和組態保留在您的 DAG 檔案中,以便可以使用原始碼控制進行版本控制;變數實際上僅適用於真正依賴執行時期的值。

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

這個條目是否有幫助?