我有airflow在一個docker容器上運行。我正在使用 airflow 2.0.2版本。
我知道我實際上可以通過用戶界面創建池。但我正在尋找一種方法,通過pools.json檔案,在docker構建時以編程方式創建池。有什么方法可以幫助我嗎?
您可以通過REST API或CLI以編程方式完成。REST API允許通過HTTP逐個添加池子。CLI有一個命令,用于從JSON檔案中匯入池:
。airflow pools import [-h] [-v] FILEPATH
例如:
{}。
"pool_1": {"slots": 5, "description"/span>: ""},
"pool_2": {"插槽"。 5, "description"/span>: "test"}{/span>
}
格式是。"[pool name]"。{"slots": [nr of slots], "description": "[描述]"}
airflow pools import pools.json
該命令是空閑的,所以你可以隨意運行它。對現有池子的修改會導致更新,新的池子會被創建。從pools.json中洗掉一個池子并不會在Airflow中洗掉該池子--你必須手動完成。
由于它的作業是empotentent的,你可以在你的Airflow鏡像中建立一個pools.json檔案,并在你的容器行程開始時運行airflow pools import,這樣就可以在每個Airflow容器的開始時檢查池。
轉載請註明出處,本文鏈接:https://www.uj5u.com/gongcheng/326371.html
標籤:
