本文介紹如何在任務管理頁面對調度任務進行一系列操作。
創建調度任務
創建任務前,請確保您已經創建了任務分組。更多信息,請參見應用管理。
- 登錄分布式任務調度平臺。
在頂部菜單欄選擇地域。
在左側導航欄,選擇任務管理。
在任務管理頁面,選擇目標命名空間,單擊創建任務。在基本配置配置向導頁,配置調度任務的相關信息,然后單擊下一步。
基本配置參數說明如下:
配置名稱
說明
任務名
自定義任務名稱。
描述
任務描述,盡量簡潔地描述業務,便于后續搜索。
應用ID
任務所屬分組。可以在下拉列表中選擇。
任務類型
指任務所實現的語言,當前支持java、xxljob、springschedule、golang、腳本任務、http和dataworks類型。選擇腳本任務時,需選擇腳本語言:shell、python或go,您可以在編輯框中編寫任務腳本。
Class全路徑
說明僅任務類型選擇java時出現。
JobProcessor的全路徑,例如
xxx.xxx.xxx.HelloProcessor
。執行模式
執行模式,這里特指任務執行的模式,當前支持以下模式。
單機運行:隨機選一臺機器執行。
廣播運行:所有機器同時執行并等待全部結束。
可視化MapReduce:Map模型,子任務300以下,有子任務列表。
專業版可支持至1,000以下,且支持業務關鍵字查詢。
MapReduce:屬于常規MapReduce模型任務,能支持超大數量的子任務并行處理,僅可查詢子任務運行匯總信息,建議子任務100W以下時選擇。
分片運行:類似elastic-job模型,配置分片參數,可以將分片平均分給多個客戶端執行。支持多語言版本。
說明當選擇不同執行模式后,高級設置中的參數會隨之變化。
任務參數
任意字符串,可以在運行時通過上下文獲取。
高級配置參數說明如下:
參數
適用的執行模式
解釋
默認值
實例失敗重試次數
通用
任務運行失敗自動重試的次數。
說明正在執行任務的機器重啟,任務會變成失敗狀態,如果想立即重跑,可以配置該參數。
0
實例失敗重試間隔
通用
每次失敗重試的間隔。單位:秒。
30
實例并發數
通用
同一個Job同一時間運行的實例個數。1表示不允許重復執行。
1
子任務單機并發數
并行計算
內存網格
網格計算
分布式模型,單臺機器并發消費子任務的個數。
5
子任務失敗重試次數
并行計算
內存網格
網格計算
分布式模型,子任務失敗自動重試的次數。
0
子任務失敗重試間隔
并行計算
內存網格
網格計算
分布式模型,子任務失敗自動重試的間隔。單位:秒。
0
子任務分發方式
并行計算
內存網格
網格計算
推模型:每臺機器平均分配子任務。
拉模型: 每臺機器主動拉取子任務,沒有木桶效應。拉取過程中,所有子任務會緩存在Master節點,對內存有壓力,建議子任務數不超過10,000。
推模型
子任務單次拉取數(僅適用于拉模型)
并行計算
內存網格
網格計算
Slave節點每次向Master節點拉取多少個子任務。
5
子任務隊列容量(僅適用于拉模型)
并行計算
內存網格
網格計算
Slave節點緩存子任務的隊列大小。
10
子任務全局并發數(僅適用于拉模型)
并行計算
內存網格
網格計算
分布式拉模型支持全局子任務并發數,可以進行限流。
1,000
在定時配置配置向導頁,設置定時參數和高級配置參數,然后單擊下一步。
定時參數說明如下:
配置項
說明
時間類型
none:無調度方式,一般通過工作流觸發。
cron:Cron表達式。
api:通過API觸發。
fixed_rate:固定頻率。
second_delay:秒級固定延遲。
onetime:一次性任務。
unix cron:unix系統下的cron表達式。
cron表達式(僅適用于cron時間類型)
填寫Cron表達式。可以直接按照Cron語法填寫,也可以使用工具生成并驗證。
固定頻率(僅適用于fixed_rate時間類型)
填寫固定頻率,單位為秒,只支持60秒以上。例如200表示每200s調度一次。
固定延遲(僅適用于second_delay時間類型)
填寫固定延遲,單位為秒。范圍為1秒~60秒。例如5表示延遲5秒觸發調度。
調度時間(僅適用于onetime時間類型)
填寫任務指定的執行時間。例如:
2023-7-13 00:00:00
。unix cron表達式(僅適用于unix cron時間類型)
填寫unix系統格式的cron表達式。
高級配置參數說明如下:
配置項
說明
時間偏移
數據時間相對于調度時間的偏移,可以在調度時從上下文獲取該值。
時區
可以根據實際情況選擇不同時區,包括一些常用國家或地區,也包括標準的GMT表達方式。
在通知配置配置向導頁,設置報警參數及聯系人,然后單擊完成。
返回任務管理頁面,查看剛才創建的任務是否已存在,且參數是否和配置一致。
說明調度任務創建完成后,默認為啟用狀態。您也可以根據實際情況禁用、再啟用該任務。具體操作,請參見啟用和禁用調度任務。
編輯調度任務
在任務管理頁面,單擊目標任務的操作列下的編輯。
在編輯面板,設置基本配置、定時配置和報警配置參數。
說明任務分組和任務類型在編輯時不可修改。其它參數配置規則和創建調度任務時一致。
執行調度任務
在任務管理頁面任務列表的操作列下的運行一次,可以執行一次該調度任務。
啟用和禁用調度任務
單個調度任務啟用和禁用
在任務管理頁面,單擊目標任務操作列下的圖標,然后單擊禁用或者啟用。
在確認對話框單擊確認。
批量啟用和禁用調度任務
如果是專業版應用,您可以批量啟用和禁用調度任務。在任務管理頁面,勾選目標任務,然后單擊任務列表下方的批量禁用或批量啟用。
復制調度任務
在任務管理頁面,單擊目標任務操作列下的圖標,然后單擊復制。可以復制該調度任務的配置,您可以編輯復制的任務,生成新的調度任務。
重刷調度任務
如果您的業務發生變更,如數據庫增加一個字段或者上一個月數據有錯誤,需要把過去一段時間的任務重新執行一遍,可以重刷調度任務數據。
任務和工作流都支持重刷數據(只支持天級別的調度周期)。
如果您之前執行的某個調度任務的數據出現偏差或遺漏,您可以通過重新設置執行參數并執行某個調度任務屬性、獲取數據。
- 登錄分布式任務調度平臺。
在任務管理頁面,單擊目標任務操作列下的圖標,然后單擊重刷任務。
在重刷任務面板,設置起止日期和數據時間,單擊確定。
起止日期:指定重刷的日期區間。
數據時間:指定重刷日期區間內的重刷時間。
示例重刷配置如下:
當前時間為2019-01-01 10:00:00。
重刷任務的起止日期為2018-10-01~2018-10-07,默認從2018年10月1日00:00:00起,到2018年10月7日23:59:59結束。
數據時間為11:11:11。
則該任務會被重刷7次,生成7個實例。
序號
調度時間
數據時間
1
2019.1.1 10:00:00
2018.10.1 11:11:11
2
2019.1.1 10:00:00
2018.10.2 11:11:11
3
2019.1.1 10:00:00
2018.10.3 11:11:11
4
2019.1.1 10:00:00
2018.10.4 11:11:11
5
2019.1.1 10:00:00
2018.10.5 11:11:11
6
2019.1.1 10:00:00
2018.10.6 11:11:11
7
2019.1.1 10:00:00
2018.10.7 11:11:11
查看調度任務的執行記錄和操作記錄
查看執行記錄:在任務管理頁面,單擊目標任務操作列下的圖標,單擊歷史記錄,查看該調度任務的執行記錄。
查看操作記錄:在任務管理頁面,單擊目標任務操作列下的圖標,單擊操作記錄,查看該調度任務的管理操作記錄。
刪除調度任務
在任務管理頁面,單擊目標任務操作列下的圖標,單擊刪除。
在彈出的確認對話框中單擊確認。
導入或導出任務
在任務管理頁面,選擇應用(專業版的應用)。
單擊導入任務或者導出任務即可。