Microservices Engine：任務管理

建立調度任務

1. 登入MSE SchedulerX控制台。

2. 在左側導覽列，單擊任務管理，並選擇需要建立任務的地區和所屬命名空間。

3. 單擊建立任務，在基本配置嚮導頁，配置調度任務的相關資訊，然後單擊下一步。

   基本配置參數說明如下：

   配置名稱	說明
   任務名	自訂任務名稱。
   描述	任務描述，盡量簡潔地描述業務，便於後續搜尋。
   應用ID	任務所屬分組。可以在下拉式清單中選擇。
   任務類型	指任務所實現的語言，當前支援Java、XXL-JOB、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
   清理策略	通用	任務執行記錄的清理策略。	保留最近N條
   保留記錄數	通用	任務歷史執行記錄的保留記錄數。	300條
   子任務單機並發數	可視化MapReduce MapReduce 分區運行	分布式模型，單台機器並發消費子任務的個數。如需加快執行速度，可以調大該值。如果下遊或者資料庫無法承接，可適當調小。	5
   子任務失敗重試次數	可視化MapReduce MapReduce 分區運行	分布式模型，子任務失敗自動重試的次數。	0
   子任務失敗稍候再試	可視化MapReduce MapReduce 分區運行	分布式模型，子任務失敗自動重試的間隔。單位：秒。	0
   子任務failover策略	可視化MapReduce MapReduce 分區運行	當執行節點宕機下線後，是否將子任務重新分發給其他機器執行。開啟該配置後，發生failover時，子任務可能會重複執行，需自行做好等冪。 說明 用戶端版本為1.8.13及以上。
   主節點參與執行	可視化MapReduce MapReduce 分區運行	主節點是否參與子任務執行。線上可運行Worker數量必須不低於2台，在子任務數量特別大時，推薦關閉該參數。 說明 用戶端版本為1.8.13及以上。
   子任務分發方式	可視化MapReduce MapReduce 分區運行	推模型：每台機器平均分配子任務。 拉模型： 每台機器主動拉取子任務，沒有木桶效應。拉取過程中，所有子任務會緩衝在Master節點，對記憶體有壓力，建議子任務數不超過10,000。	推模型
   分發策略	可視化MapReduce MapReduce	子任務分發策略，預設採用各個節點輪詢分發。 輪詢策略：每個worker平均分配等量子任務，適用於每個子任務處理耗時基本一致的情境。 負載最優策略：由主節點自動感知worker節點各自負載情況，適用子任務和worker機器處理耗時有較大差異的情境。 說明 用戶端版本為1.10.14及以上。
   分發速率	可視化MapReduce MapReduce	子任務分發速率，支援每秒或每分鐘分發多少個子任務。
   子任務單次拉取數（僅適用於拉模型）	可視化MapReduce MapReduce 分區運行	Slave節點每次向Master節點拉取多少個子任務。	5
   子任務隊列容量（僅適用於拉模型）	可視化MapReduce MapReduce 分區運行	Slave節點緩衝子任務的隊列大小。	10
   子任務全域並發數（僅適用於拉模型）	可視化MapReduce MapReduce 分區運行	分布式拉模型支援全域子任務並發數，可以進行限流。	1,000

4. 在定時配置設定精靈頁，設定定時參數和進階配置參數，然後單擊下一步。

   

   定時參數說明如下：

   配置項	說明
   時間類型	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表達方式。

5. 在通知配置設定精靈頁，設定警示參數及連絡人，然後單擊完成。

   

   通知渠道及連絡人目前支援應用分組連絡人、自訂。

   • 應用分組連絡人

     應用分組連絡人下所有連絡人都可接收到通知。

   • 自訂

     自訂中通知方式支援連絡人群組、連絡人兩種方式。

     • 連絡人群組

       連絡人群組下所有連絡人都可以接收到通知。關於建立連絡人群組，請參見通知連絡人。

     • 連絡人

       1.添加通知連絡人，添加的連絡人可以接收到通知。支援設定多個通知連絡人。新增連絡人...後，單擊前往建立連絡人。

       

       2.在彈出頁面中單擊建立連絡人，然後輸入連絡人資訊。

       

       

6. 返回任務管理頁面，查看剛才建立的任務是否已存在，且參數是否和配置一致。

   說明

   調度任務建立完成後，預設為啟用狀態。您也可以根據實際情況禁用、再啟用該任務。具體操作，請參見啟用和禁用調度任務。

編輯調度任務

1. 在任務管理頁面，單擊目標任務的操作列下的編輯。

   

2. 在編輯面板，設定基本配置、定時配置和警示配置參數。

   說明

   任務分組和任務類型在編輯時不可修改。其他參數配置規則和建立調度任務時一致。

執行調度任務

在任務管理頁面工作清單的操作列下單擊運行一次，可以執行一次該調度任務。

啟用和禁用調度任務

複製調度任務

在任務管理頁面，單擊目標任務操作列下的更多>複製。可以複製該調度任務的配置，您可以編輯複製的任務，產生新的調度任務。

重刷調度任務

如果您的業務發生變更，如資料庫增加一個欄位或者上一個月資料有錯誤，需要把過去一段時間的任務重新執行一遍，可以重刷調度任務資料。

如果您之前執行的某個調度任務的資料出現偏差或遺漏，您可以通過重新設定執行參數並執行某個調度任務屬性、擷取資料。

1. 登入MSE SchedulerX控制台。

2. 在任務管理頁面，單擊目標任務操作列下的更多，然後單擊重刷任務。

3. 在重刷任務面板，設定起止日期和資料時間，單擊確定。

   • 起止日期：指定重刷的日期區間。

   • 資料時間：指定重刷日期區間內的重刷時間。

   

   樣本重刷配置如下：

   • 目前時間為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

查看調度任務的執行記錄和操作記錄

• 查看執行記錄：在任務管理頁面，單擊目標任務操作列下的更多>記錄，查看該調度任務的執行記錄。

• 查看操作記錄：在任務管理頁面，單擊目標任務操作列下的更多>操作記錄，查看該調度任務的管理操作記錄。

刪除調度任務

1. 在任務管理頁面，單擊目標任務操作列下的更多>刪除。

   

2. 在彈出的確認對話方塊中單擊確認。

匯入或匯出任務

1. 在任務管理頁面，選擇應用（專業版的應用）。

   

2. 單擊匯入任務或者匯出任務即可。