SchedulerX可以處理有資料狀態的任務,您可以通過資料時間處理非任務執行時間的資料。
操作步驟
例如一個任務在每天00:30運行,但是實際上要處理前一天的資料,即資料時間需要在任務時間的基礎上,向前位移一小時。
-
在用戶端中接入SchedulerX,詳情請參見快速入門章節,並實現資料時間。
public class TestHelloJob extends JavaProcessor { @Override public ProcessResult process(JobContext context) throws Exception { System.out.println("hello schedulerx2.0"); System.out.println("dataTime=" + context.getDataTime().toString("yyyy-MM-dd HH:mm:ss")); return new ProcessResult(true); } } -
在控制台建立任務,詳情請參見建立調度任務。並在定时配置中設定时间偏移-3600(單位:秒),即向前位移3600 秒(一小時)。任務執行時間不變,執行的時候通過
context.getDataTime()擷取的是前一天23:30的資料。
結果驗證
-
在包含資料時間的任務建立完成後,進入执行列表頁面,找到對應的任務,在操作列單擊详情。
-
在任务实例详情頁面單擊基本信息。
-
在基本信息頁簽中確認任務的数据时间是否和設定的一致。