變數¶
變數是 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 檔案中,以便可以使用原始碼控制進行版本控制;變數確實只用於真正依賴於執行時的值。
有關設定和管理變數的更多資訊,請參閱管理變數。