我在從代碼下載所有 Airflow 變量時遇到問題。有機會從 UI 導出，但我還沒有找到任何以編程方式進行導出的方法。我發(fā)現(xiàn)了唯一Variable.get('variable_name')返回一個 Airflow 變量的方法。沒有獲取氣流變量列表的變體。在源代碼中搜索也沒有幫助。你知道一些簡單的方法嗎？先感謝您。
3 回答
HUWWW
TA貢獻1874條經(jīng)驗 獲得超12個贊
您可以使用 Airflow CLI 將變量導出到文件，然后從 Python 代碼中讀取它。
airflow variables --export FILEPATH
以編程方式，您可以使用BashOperator來實現(xiàn)此目的。
千萬里不及你
TA貢獻1784條經(jīng)驗 獲得超9個贊
我在這個用例中使用 BashOperator 有問題，所以我將 bashcommand 的結(jié)果復(fù)制到一個變量并在我的程序中使用它。
import subprocess
output = (subprocess.check_output("airflow variables", shell=True)).decode('utf-8').split('pid=')[1].split()[1:-1]
print(output)
添加回答
舉報
0/150
提交
取消