<ruby id="bdb3f"></ruby>

    <p id="bdb3f"><cite id="bdb3f"></cite></p>

      <p id="bdb3f"><cite id="bdb3f"><th id="bdb3f"></th></cite></p><p id="bdb3f"></p>
        <p id="bdb3f"><cite id="bdb3f"></cite></p>

          <pre id="bdb3f"></pre>
          <pre id="bdb3f"><del id="bdb3f"><thead id="bdb3f"></thead></del></pre>

          <ruby id="bdb3f"><mark id="bdb3f"></mark></ruby><ruby id="bdb3f"></ruby>
          <pre id="bdb3f"><pre id="bdb3f"><mark id="bdb3f"></mark></pre></pre><output id="bdb3f"></output><p id="bdb3f"></p><p id="bdb3f"></p>

          <pre id="bdb3f"><del id="bdb3f"><progress id="bdb3f"></progress></del></pre>

                <ruby id="bdb3f"></ruby>

                合規國際互聯網加速 OSASE為企業客戶提供高速穩定SD-WAN國際加速解決方案。 廣告
                # 命令行界面 Airflow具有非常豐富的命令行界面,允許在DAG上執行多種類型的操作,啟動服務以及支持開發和測試。 ``` usage : airflow [ - h ] { resetdb , render , variables , connections , create_user , pause , task_failed_deps , version , trigger_dag , initdb , test , unpause , dag_state , run , list_tasks , backfill , list_dags , kerberos , worker , webserver , flower , scheduler , task_state , pool , serve_logs , clear , upgradedb , delete_dag } ... ``` ## 位置參數 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;子&lt;/kbd&gt; | 可能的選擇:resetdb,render,variables,connections,create_user,pause,task_failed_deps,version,trigger_dag,initdb,test,unpause,dag_state,run,list_tasks,backfill,list_dags,kerberos,worker,webserver,flower,scheduler,task_state,pool ,serve_logs,clear,upgrab,delete_dag子命令幫助 | ## 子命令: ### resetdb 燒毀并重建元數據數據庫 ``` airflow resetdb [ - h ] [ - y ] ``` #### 命名參數 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;-y, - 是的&lt;/kbd&gt; | 不要提示確認重置。 小心使用!默認值:False | ### 給予 渲染任務實例的模板 ``` airflow render [ - h ] [ - sd SUBDIR ] dag_id task_id execution_date ``` #### 位置參數 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;dag_id&lt;/kbd&gt; | dag的id | | &lt;kbd&gt;TASK_ID&lt;/kbd&gt; | 任務的id | | &lt;kbd&gt;執行日期&lt;/kbd&gt; | DAG的執行日期 | #### 命名參數 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;-sd, - subdir&lt;/kbd&gt; | 從中查找dag的文件位置或目錄默認值:/ Users / kaxil / airflow / dags | ### 變量 對變量的CRUD操作 ``` airflow variables [ - h ] [ - s KEY VAL ] [ - g KEY ] [ - j ] [ - d VAL ] [ - i FILEPATH ] [ - e FILEPATH ] [ - x KEY ] ``` #### 命名參數 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;-s, - set&lt;/kbd&gt; | 設置變量 | | &lt;kbd&gt;-g, - get&lt;/kbd&gt; | 獲取變量的值 | | &lt;kbd&gt;-j, - json&lt;/kbd&gt; | 反序列化JSON變量默認值:False | | &lt;kbd&gt;-d, - 默認&lt;/kbd&gt; | 如果變量不存在,則返回默認值 | | &lt;kbd&gt;-i, - 進口&lt;/kbd&gt; | 從JSON文件導入變量 | | &lt;kbd&gt;-e, - 出口&lt;/kbd&gt; | 將變量導出到JSON文件 | | &lt;kbd&gt;-x, - 刪除&lt;/kbd&gt; | 刪除變量 | ### 連接 列表/添加/刪除連接 ``` airflow connections [ - h ] [ - l ] [ - a ] [ - d ] [ -- conn_id CONN_ID ] [ -- conn_uri CONN_URI ] [ -- conn_extra CONN_EXTRA ] [ -- conn_type CONN_TYPE ] [ -- conn_host CONN_HOST ] [ -- conn_login CONN_LOGIN ] [ -- conn_password CONN_PASSWORD ] [ -- conn_schema CONN_SCHEMA ] [ -- conn_port CONN_PORT ] ``` #### 命名參數 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;-l, - list&lt;/kbd&gt; | 列出所有連接默認值:False | | &lt;kbd&gt;-a, - add&lt;/kbd&gt; | 添加連接默認值:False | | &lt;kbd&gt;-d, - 刪除&lt;/kbd&gt; | 刪除連接默認值:False | | &lt;kbd&gt;--conn_id&lt;/kbd&gt; | 添加/刪除連接所需的連接ID | | &lt;kbd&gt;--conn_uri&lt;/kbd&gt; | 連接URI,添加沒有conn_type的連接所需 | | &lt;kbd&gt;--conn_extra&lt;/kbd&gt; | 連接&lt;cite&gt;額外&lt;/cite&gt;字段,添加連接時可選 | | &lt;kbd&gt;--conn_type&lt;/kbd&gt; | 連接類型,無需conn_uri即可添加連接 | | &lt;kbd&gt;--conn_host&lt;/kbd&gt; | 連接主機,添加連接時可選 | | &lt;kbd&gt;--conn_login&lt;/kbd&gt; | 連接登錄,添加連接時可選 | | &lt;kbd&gt;--conn_password&lt;/kbd&gt; | | | 連接密碼,添加連接時可選 | | &lt;kbd&gt;--conn_schema&lt;/kbd&gt; | 連接架構,添加連接時可選 | | &lt;kbd&gt;--conn_port&lt;/kbd&gt; | 連接端口,添加連接時可選 | ### 創建用戶 創建管理員帳戶 ``` airflow create_user [ - h ] [ - r ROLE ] [ - u USERNAME ] [ - e EMAIL ] [ - f FIRSTNAME ] [ - l LASTNAME ] [ - p PASSWORD ] [ -- use_random_password ] ``` #### 命名參數 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;-r,--role&lt;/kbd&gt; | 用戶的角色。 現有角色包括Admin,User,Op,Viewer和Public | | &lt;kbd&gt;-u, - username&lt;/kbd&gt; | 用戶的用戶名 | | &lt;kbd&gt;-e, - 電子郵件&lt;/kbd&gt; | 用戶的電子郵件 | | &lt;kbd&gt;-f, - firstname&lt;/kbd&gt; | | | 用戶的名字 | | &lt;kbd&gt;-l,--lastname&lt;/kbd&gt; | 用戶的姓氏 | | &lt;kbd&gt;-p, - 密碼&lt;/kbd&gt; | 用戶密碼 | | &lt;kbd&gt;--use_random_password&lt;/kbd&gt; | | | 不要提示輸入密碼。 改為使用隨機字符串默認值:False | ### 暫停 暫停DAG ``` airflow pause [ - h ] [ - sd SUBDIR ] dag_id ``` #### 位置參數 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;dag_id&lt;/kbd&gt; | dag的id | #### 命名參數 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;-sd, - subdir&lt;/kbd&gt; | 從中查找dag的文件位置或目錄默認值:/ Users / kaxil / airflow / dags | ### task_failed_deps 從調度程序的角度返回任務實例的未滿足的依賴項。 換句話說,為什么任務實例不會被調度程序調度然后排隊,然后由執行程序運行。 ``` airflow task_failed_deps [ - h ] [ - sd SUBDIR ] dag_id task_id execution_date ``` #### 位置參數 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;dag_id&lt;/kbd&gt; | dag的id | | &lt;kbd&gt;TASK_ID&lt;/kbd&gt; | 任務的id | | &lt;kbd&gt;執行日期&lt;/kbd&gt; | DAG的執行日期 | #### 命名參數 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;-sd, - subdir&lt;/kbd&gt; | 從中查找dag的文件位置或目錄默認值:/ Users / kaxil / airflow / dags | ### 版 顯示版本 ``` airflow version [ - h ] ``` ### trigger_dag 觸發DAG運行 ``` airflow trigger_dag [ - h ] [ - sd SUBDIR ] [ - r RUN_ID ] [ - c CONF ] [ - e EXEC_DATE ] dag_id ``` #### 位置參數 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;dag_id&lt;/kbd&gt; | dag的id | #### 命名參數 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;-sd, - subdir&lt;/kbd&gt; | 從中查找dag的文件位置或目錄默認值:/ Users / kaxil / airflow / dags | | &lt;kbd&gt;-r, - run_id&lt;/kbd&gt; | 幫助識別此次運行 | | &lt;kbd&gt;-c, - conf&lt;/kbd&gt; | JSON字符串被腌制到DagRun的conf屬性中 | | &lt;kbd&gt;-e, - exec_date&lt;/kbd&gt; | | | DAG的執行日期 | ### 在initdb 初始化元數據數據庫 ``` airflow initdb [ - h ] ``` ### 測試 測試任務實例。 這將在不檢查依賴關系或在數據庫中記錄其狀態的情況下運行任務。 ``` airflow test [ - h ] [ - sd SUBDIR ] [ - dr ] [ - tp TASK_PARAMS ] dag_id task_id execution_date ``` #### 位置參數 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;dag_id&lt;/kbd&gt; | dag的id | | &lt;kbd&gt;TASK_ID&lt;/kbd&gt; | 任務的id | | &lt;kbd&gt;執行日期&lt;/kbd&gt; | DAG的執行日期 | #### 命名參數 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;-sd, - subdir&lt;/kbd&gt; | 從中查找dag的文件位置或目錄默認值:/ Users / kaxil / airflow / dags | | &lt;kbd&gt;-dr, - dr_run&lt;/kbd&gt; | 進行干運行默認值:False | | &lt;kbd&gt;-tp, - task_params&lt;/kbd&gt; | | | 向任務發送JSON params dict | ### 取消暫停 恢復暫停的DAG ``` airflow unpause [ - h ] [ - sd SUBDIR ] dag_id ``` #### 位置參數 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;dag_id&lt;/kbd&gt; | dag的id | #### 命名參數 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;-sd, - subdir&lt;/kbd&gt; | 從中查找dag的文件位置或目錄默認值:/ Users / kaxil / airflow / dags | ### dag_state 獲取dag run的狀態 ``` airflow dag_state [ - h ] [ - sd SUBDIR ] dag_id execution_date ``` #### 位置參數 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;dag_id&lt;/kbd&gt; | dag的id | | &lt;kbd&gt;執行日期&lt;/kbd&gt; | DAG的執行日期 | #### 命名參數 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;-sd, - subdir&lt;/kbd&gt; | 從中查找dag的文件位置或目錄默認值:/ Users / kaxil / airflow / dags | ### 跑 運行單個任務實例 ``` airflow run [ - h ] [ - sd SUBDIR ] [ - m ] [ - f ] [ -- pool POOL ] [ -- cfg_path CFG_PATH ] [ - l ] [ - A ] [ - i ] [ - I ] [ -- ship_dag ] [ - p PICKLE ] [ - int ] dag_id task_id execution_date ``` #### 位置參數 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;dag_id&lt;/kbd&gt; | dag的id | | &lt;kbd&gt;TASK_ID&lt;/kbd&gt; | 任務的id | | &lt;kbd&gt;執行日期&lt;/kbd&gt; | DAG的執行日期 | #### 命名參數 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;-sd, - subdir&lt;/kbd&gt; | 從中查找dag的文件位置或目錄默認值:/ Users / kaxil / airflow / dags | | &lt;kbd&gt;-m, - mark_success&lt;/kbd&gt; | | | 將作業標記為成功而不運行它們默認值:False | | &lt;kbd&gt;-f, - force&lt;/kbd&gt; | 忽略先前的任務實例狀態,無論任務是否已成功/失敗,都重新運行默認值:False | | &lt;kbd&gt;--pool&lt;/kbd&gt; | 要使用的資源池 | | &lt;kbd&gt;--cfg_path&lt;/kbd&gt; | 要使用的配置文件的路徑而不是airflow.cfg | | &lt;kbd&gt;-l, - 本地&lt;/kbd&gt; | 使用LocalExecutor運行任務默認值:False | | &lt;kbd&gt;-A, - ignore_all_dependencies&lt;/kbd&gt; | | | 忽略所有非關鍵依賴項,包括ignore_ti_state和ignore_task_deps默認值:False | | &lt;kbd&gt;-i,--ignore_dependencies&lt;/kbd&gt; | | | 忽略特定于任務的依賴項,例如upstream,depends_on_past和重試延遲依賴項默認值:False | | &lt;kbd&gt;-I, - signore_depends_on_past&lt;/kbd&gt; | | | 忽略depends_on_past依賴項(但尊重上游依賴項)默認值:False | | &lt;kbd&gt;--ship_dag&lt;/kbd&gt; | 泡菜(序列化)DAG并將其運送給工人默認值:False | | &lt;kbd&gt;-p, - pickle&lt;/kbd&gt; | 整個dag的序列化pickle對象(內部使用) | | &lt;kbd&gt;-int, - interactive&lt;/kbd&gt; | | | 不捕獲標準輸出和錯誤流(對交互式調試很有用)默認值:False | ### list_tasks 列出DAG中的任務 ``` airflow list_tasks [ - h ] [ - t ] [ - sd SUBDIR ] dag_id ``` #### 位置參數 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;dag_id&lt;/kbd&gt; | dag的id | #### 命名參數 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;-t, - 樹&lt;/kbd&gt; | 樹視圖默認值:False | | &lt;kbd&gt;-sd, - subdir&lt;/kbd&gt; | 從中查找dag的文件位置或目錄默認值:/ Users / kaxil / airflow / dags | ### 回填 在指定的日期范圍內運行DAG的子部分。 如果使用reset_dag_run選項,則回填將首先提示用戶氣流是否應清除回填日期范圍內的所有先前dag_run和task_instances。如果使用rerun_failed_tasks,則回填將自動重新運行回填日期范圍內的先前失敗的任務實例。 ``` airflow backfill [ - h ] [ - t TASK_REGEX ] [ - s START_DATE ] [ - e END_DATE ] [ - m ] [ - l ] [ - x ] [ - i ] [ - I ] [ - sd SUBDIR ] [ -- pool POOL ] [ -- delay_on_limit DELAY_ON_LIMIT ] [ - dr ] [ - v ] [ - c CONF ] [ -- reset_dagruns ] [ -- rerun_failed_tasks ] dag_id ``` #### 位置參數 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;dag_id&lt;/kbd&gt; | dag的id | #### 命名參數 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;-t, - task_regex&lt;/kbd&gt; | | | 用于過濾特定task_ids以回填的正則表達式(可選) | | &lt;kbd&gt;-s, - start_date&lt;/kbd&gt; | | | 覆蓋start_date YYYY-MM-DD | | &lt;kbd&gt;-e, - end_date&lt;/kbd&gt; | 覆蓋end_date YYYY-MM-DD | | &lt;kbd&gt;-m, - mark_success&lt;/kbd&gt; | | | 將作業標記為成功而不運行它們默認值:False | | &lt;kbd&gt;-l, - 本地&lt;/kbd&gt; | 使用LocalExecutor運行任務默認值:False | | &lt;kbd&gt;-x, - donot_pickle&lt;/kbd&gt; | | | 不要試圖挑選DAG對象發送給工人,只要告訴工人運行他們的代碼版本。默認值:False | | &lt;kbd&gt;-i,--ignore_dependencies&lt;/kbd&gt; | | | 跳過上游任務,僅運行與正則表達式匹配的任務。 僅適用于task_regex默認值:False | | &lt;kbd&gt;-I, - signore_first_depends_on_past&lt;/kbd&gt; | | | 僅忽略第一組任務的depends_on_past依賴關系(回填DO中的后續執行依賴depends_on_past)。默認值:False | | &lt;kbd&gt;-sd, - subdir&lt;/kbd&gt; | 從中查找dag的文件位置或目錄默認值:/ Users / kaxil / airflow / dags | | &lt;kbd&gt;--pool&lt;/kbd&gt; | 要使用的資源池 | | &lt;kbd&gt;--delay_on_limit&lt;/kbd&gt; | | | 在嘗試再次執行dag運行之前達到最大活動dag運行限制(max_active_runs)時等待的時間(以秒為單位)。默認值:1.0 | | &lt;kbd&gt;-dr, - dr_run&lt;/kbd&gt; | 進行干運行默認值:False | | &lt;kbd&gt;-v, - verbose&lt;/kbd&gt; | 使日志輸出更詳細默認值:False | | &lt;kbd&gt;-c, - conf&lt;/kbd&gt; | JSON字符串被腌制到DagRun的conf屬性中 | | &lt;kbd&gt;--reset_dagruns&lt;/kbd&gt; | | | 如果設置,則回填將刪除現有的與回填相關的DAG運行,并重新開始運行新的DAG運行默認值:False | | &lt;kbd&gt;--rerun_failed_tasks&lt;/kbd&gt; | | | 如果設置,則回填將自動重新運行回填日期范圍的所有失敗任務,而不是拋出異常默認值:False | ### list_dags 列出所有DAG ``` airflow list_dags [ - h ] [ - sd SUBDIR ] [ - r ] ``` #### 命名參數 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;-sd, - subdir&lt;/kbd&gt; | 從中查找dag的文件位置或目錄默認值:/ Users / kaxil / airflow / dags | | &lt;kbd&gt;-r, - 報告&lt;/kbd&gt; | 顯示DagBag加載報告默認值:False | ### Kerberos的 啟動kerberos票證續訂 ``` airflow kerberos [ - h ] [ - kt [ KEYTAB ]] [ -- pid [ PID ]] [ - D ] [ -- stdout STDOUT ] [ -- stderr STDERR ] [ - l LOG_FILE ] [ principal ] ``` #### 位置參數 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;主要&lt;/kbd&gt; | 凱伯羅斯校長默認值:氣流 | #### 命名參數 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;-kt, - keytab&lt;/kbd&gt; | 密鑰表默認值:airflow.keytab | | &lt;kbd&gt;--pid&lt;/kbd&gt; | PID文件位置 | | &lt;kbd&gt;-D, - damon&lt;/kbd&gt; | 守護進程而不是在前臺運行默認值:False | | &lt;kbd&gt;--stdout&lt;/kbd&gt; | 將stdout重定向到此文件 | | &lt;kbd&gt;--stderr&lt;/kbd&gt; | 將stderr重定向到此文件 | | &lt;kbd&gt;-l, - log-file&lt;/kbd&gt; | 日志文件的位置 | ### 工人 啟動Celery工作節點 ``` airflow worker [ - h ] [ - p ] [ - q QUEUES ] [ - c CONCURRENCY ] [ - cn CELERY_HOSTNAME ] [ -- pid [ PID ]] [ - D ] [ -- stdout STDOUT ] [ -- stderr STDERR ] [ - l LOG_FILE ] ``` #### 命名參數 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;-p, - do_pickle&lt;/kbd&gt; | | | 嘗試將DAG對象發送給工作人員,而不是讓工作人員運行他們的代碼版本。默認值:False | | &lt;kbd&gt;-q, - 隊列&lt;/kbd&gt; | 以逗號分隔的隊列列表默認值:默認值 | | &lt;kbd&gt;-c, - 并發&lt;/kbd&gt; | | | 工作進程的數量默認值:16 | | &lt;kbd&gt;-cn, - slowry_hostname&lt;/kbd&gt; | | | 如果一臺計算機上有多個worker,請設置芹菜工作者的主機名。 | | &lt;kbd&gt;--pid&lt;/kbd&gt; | PID文件位置 | | &lt;kbd&gt;-D, - damon&lt;/kbd&gt; | 守護進程而不是在前臺運行默認值:False | | &lt;kbd&gt;--stdout&lt;/kbd&gt; | 將stdout重定向到此文件 | | &lt;kbd&gt;--stderr&lt;/kbd&gt; | 將stderr重定向到此文件 | | &lt;kbd&gt;-l, - log-file&lt;/kbd&gt; | 日志文件的位置 | ### 網絡服務器 啟動Airflow網絡服務器實例 ``` airflow webserver [ - h ] [ - p PORT ] [ - w WORKERS ] [ - k { sync , eventlet , gevent , tornado }] [ - t WORKER_TIMEOUT ] [ - hn HOSTNAME ] [ -- pid [ PID ]] [ - D ] [ -- stdout STDOUT ] [ -- stderr STDERR ] [ - A ACCESS_LOGFILE ] [ - E ERROR_LOGFILE ] [ - l LOG_FILE ] [ -- ssl_cert SSL_CERT ] [ -- ssl_key SSL_KEY ] [ - d ] ``` #### 命名參數 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;-p, - port&lt;/kbd&gt; | 運行服務器的端口默認值:8080 | | &lt;kbd&gt;-w, - 工作人員&lt;/kbd&gt; | 運行Web服務器的工作者數量默認值:4 | | &lt;kbd&gt;-k, - workerclass&lt;/kbd&gt; | | | 可能的選擇:同步,eventlet,gevent,龍卷風用于Gunicorn的工人階級默認值:同步 | | &lt;kbd&gt;-t, - worker_timeout&lt;/kbd&gt; | | | 等待Web服務器工作者的超時時間默認值:120 | | &lt;kbd&gt;-hn, - hostname&lt;/kbd&gt; | | | 設置運行Web服務器的主機名默認值:0.0.0.0 | | &lt;kbd&gt;--pid&lt;/kbd&gt; | PID文件位置 | | &lt;kbd&gt;-D, - damon&lt;/kbd&gt; | 守護進程而不是在前臺運行默認值:False | | &lt;kbd&gt;--stdout&lt;/kbd&gt; | 將stdout重定向到此文件 | | &lt;kbd&gt;--stderr&lt;/kbd&gt; | 將stderr重定向到此文件 | | &lt;kbd&gt;-A, - access_logfile&lt;/kbd&gt; | | | 用于存儲Web服務器訪問日志的日志文件。 使用' - '打印到stderr。默認值: - | | &lt;kbd&gt;-E, - error_logfile&lt;/kbd&gt; | | | 用于存儲Web服務器錯誤日志的日志文件。 使用' - '打印到stderr。默認值: - | | &lt;kbd&gt;-l, - log-file&lt;/kbd&gt; | 日志文件的位置 | | &lt;kbd&gt;--ssl_cert&lt;/kbd&gt; | Web服務器的SSL證書的路徑 | | &lt;kbd&gt;--ssl_key&lt;/kbd&gt; | 用于SSL證書的密鑰的路徑 | | &lt;kbd&gt;-d, - debug&lt;/kbd&gt; | 在調試模式下使用Flask附帶的服務器默認值:False | ### 花 開始芹菜花 ``` airflow flower [ - h ] [ - hn HOSTNAME ] [ - p PORT ] [ - fc FLOWER_CONF ] [ - u URL_PREFIX ] [ - a BROKER_API ] [ -- pid [ PID ]] [ - D ] [ -- stdout STDOUT ] [ -- stderr STDERR ] [ - l LOG_FILE ] ``` #### 命名參數 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;-hn, - hostname&lt;/kbd&gt; | | | 設置運行服務器的主機名默認值:0.0.0.0 | | &lt;kbd&gt;-p, - port&lt;/kbd&gt; | 運行服務器的端口默認值:5555 | | &lt;kbd&gt;-fc, - flowers_conf&lt;/kbd&gt; | | | 花的配置文件 | | &lt;kbd&gt;-u, - url_prefix&lt;/kbd&gt; | | | Flower的URL前綴 | | &lt;kbd&gt;-a, - broker_api&lt;/kbd&gt; | | | 經紀人api | | &lt;kbd&gt;--pid&lt;/kbd&gt; | PID文件位置 | | &lt;kbd&gt;-D, - damon&lt;/kbd&gt; | 守護進程而不是在前臺運行默認值:False | | &lt;kbd&gt;--stdout&lt;/kbd&gt; | 將stdout重定向到此文件 | | &lt;kbd&gt;--stderr&lt;/kbd&gt; | 將stderr重定向到此文件 | | &lt;kbd&gt;-l, - log-file&lt;/kbd&gt; | 日志文件的位置 | ### 調度 啟動調度程序實例 ``` airflow scheduler [ - h ] [ - d DAG_ID ] [ - sd SUBDIR ] [ - r RUN_DURATION ] [ - n NUM_RUNS ] [ - p ] [ -- pid [ PID ]] [ - D ] [ -- stdout STDOUT ] [ -- stderr STDERR ] [ - l LOG_FILE ] ``` #### 命名參數 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;-d, - dag_id&lt;/kbd&gt; | 要運行的dag的id | | &lt;kbd&gt;-sd, - subdir&lt;/kbd&gt; | 從中查找dag的文件位置或目錄默認值:/ Users / kaxil / airflow / dags | | &lt;kbd&gt;-r, - 運行時間&lt;/kbd&gt; | | | 設置退出前執行的秒數 | | &lt;kbd&gt;-n, - num_runs&lt;/kbd&gt; | 設置退出前要執行的運行次數默認值:-1 | | &lt;kbd&gt;-p, - do_pickle&lt;/kbd&gt; | | | 嘗試將DAG對象發送給工作人員,而不是讓工作人員運行他們的代碼版本。默認值:False | | &lt;kbd&gt;--pid&lt;/kbd&gt; | PID文件位置 | | &lt;kbd&gt;-D, - damon&lt;/kbd&gt; | 守護進程而不是在前臺運行默認值:False | | &lt;kbd&gt;--stdout&lt;/kbd&gt; | 將stdout重定向到此文件 | | &lt;kbd&gt;--stderr&lt;/kbd&gt; | 將stderr重定向到此文件 | | &lt;kbd&gt;-l, - log-file&lt;/kbd&gt; | 日志文件的位置 | ### task_state 獲取任務實例的狀態 ``` airflow task_state [ - h ] [ - sd SUBDIR ] dag_id task_id execution_date ``` #### 位置參數 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;dag_id&lt;/kbd&gt; | dag的id | | &lt;kbd&gt;TASK_ID&lt;/kbd&gt; | 任務的id | | &lt;kbd&gt;執行日期&lt;/kbd&gt; | DAG的執行日期 | #### 命名參數 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;-sd, - subdir&lt;/kbd&gt; | 從中查找dag的文件位置或目錄默認值:/ Users / kaxil / airflow / dags | ### 池 池上的CRUD操作 ``` airflow pool [ - h ] [ - s NAME SLOT_COUNT POOL_DESCRIPTION ] [ - g NAME ] [ - x NAME ] ``` #### 命名參數 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;-s, - set&lt;/kbd&gt; | 分別設置池槽數和描述 | | &lt;kbd&gt;-g, - get&lt;/kbd&gt; | 獲取泳池信息 | | &lt;kbd&gt;-x, - 刪除&lt;/kbd&gt; | 刪除池 | ### serve_logs 由工人生成的服務日志 ``` airflow serve_logs [ - h ] ``` ### 明確 清除一組任務實例,就好像它們從未運行過一樣 ``` airflow clear [ - h ] [ - t TASK_REGEX ] [ - s START_DATE ] [ - e END_DATE ] [ - sd SUBDIR ] [ - u ] [ - d ] [ - c ] [ - f ] [ - r ] [ - x ] [ - dx ] dag_id ``` #### 位置參數 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;dag_id&lt;/kbd&gt; | dag的id | #### 命名參數 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;-t, - task_regex&lt;/kbd&gt; | | | 用于過濾特定task_ids以回填的正則表達式(可選) | | &lt;kbd&gt;-s, - start_date&lt;/kbd&gt; | | | 覆蓋start_date YYYY-MM-DD | | &lt;kbd&gt;-e, - end_date&lt;/kbd&gt; | 覆蓋end_date YYYY-MM-DD | | &lt;kbd&gt;-sd, - subdir&lt;/kbd&gt; | 從中查找dag的文件位置或目錄默認值:/ Users / kaxil / airflow / dags | | &lt;kbd&gt;-u, - upstream&lt;/kbd&gt; | 包括上游任務默認值:False | | &lt;kbd&gt;-d, - downstream&lt;/kbd&gt; | | | 包括下游任務默認值:False | | &lt;kbd&gt;-c, - no_confirm&lt;/kbd&gt; | | | 請勿要求確認默認值:False | | &lt;kbd&gt;-f, - only_failed&lt;/kbd&gt; | | | 只有失敗的工作默認值:False | | &lt;kbd&gt;-r, - only_running&lt;/kbd&gt; | | | 只運行工作默認值:False | | &lt;kbd&gt;-x, - exclude_subdags&lt;/kbd&gt; | | | 排除子標記默認值:False | | &lt;kbd&gt;-dx, - dag_regex&lt;/kbd&gt; | | | 將dag_id搜索為正則表達式而不是精確字符串默認值:False | ### UPGRADEDB 將元數據數據庫升級到最新版本 ``` airflow upgradedb [ - h ] ``` ### delete_dag 刪除與指定DAG相關的所有DB記錄 ``` airflow delete_dag [ - h ] [ - y ] dag_id ``` #### 位置參數 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;dag_id&lt;/kbd&gt; | dag的id | #### 命名參數 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;-y, - 是的&lt;/kbd&gt; | 不要提示確認重置。 小心使用!默認值:False |
                  <ruby id="bdb3f"></ruby>

                  <p id="bdb3f"><cite id="bdb3f"></cite></p>

                    <p id="bdb3f"><cite id="bdb3f"><th id="bdb3f"></th></cite></p><p id="bdb3f"></p>
                      <p id="bdb3f"><cite id="bdb3f"></cite></p>

                        <pre id="bdb3f"></pre>
                        <pre id="bdb3f"><del id="bdb3f"><thead id="bdb3f"></thead></del></pre>

                        <ruby id="bdb3f"><mark id="bdb3f"></mark></ruby><ruby id="bdb3f"></ruby>
                        <pre id="bdb3f"><pre id="bdb3f"><mark id="bdb3f"></mark></pre></pre><output id="bdb3f"></output><p id="bdb3f"></p><p id="bdb3f"></p>

                        <pre id="bdb3f"><del id="bdb3f"><progress id="bdb3f"></progress></del></pre>

                              <ruby id="bdb3f"></ruby>

                              哎呀哎呀视频在线观看