調(diào)度參數(shù)只支持獲取時間類型數(shù)據(jù)，部分節(jié)點（例如，離線同步節(jié)點）配置了調(diào)度參數(shù)后，調(diào)度參數(shù)的返回值不能直接使用，需要進行函數(shù)轉(zhuǎn)換等二次處理。本文為您介紹二次處理調(diào)度參數(shù)返回結(jié)果的典型場景。

背景信息

調(diào)度參數(shù)支持的時間類型未覆蓋所有的時間場景，如果您的業(yè)務(wù)需要使用特殊時間格式，則可以使用引擎函數(shù)進行處理。二次處理調(diào)度參數(shù)時，部分節(jié)點不支持直接使用函數(shù)轉(zhuǎn)換參數(shù)返回結(jié)果。對于不支持直接使用函數(shù)轉(zhuǎn)換的節(jié)點，您可以通過賦值節(jié)點進行相關(guān)處理。

直接使用函數(shù)，或通過賦值節(jié)點二次處理調(diào)度參數(shù)的典型場景如下：
更多操作參考如下：

獲取上個月最后一天

使用調(diào)度參數(shù)獲取上個月最后一天的配置及測試結(jié)果如下表。
參數(shù)配置 測試定時時間CYCTIME 返回結(jié)果
  • 調(diào)度參數(shù)配置：last_month=$[yyyy-mm]
  • 處理調(diào)度參數(shù)的返回值：SELECT REPLACE(DATEADD(date'${last_month}-01',-1,'dd'),'-','');
  • 預(yù)期返回格式：yyyymmdd
 20210926000000 20210831

獲取當(dāng)前季度

使用調(diào)度參數(shù)獲取當(dāng)前季度的配置及測試結(jié)果如下表。
參數(shù)配置 測試定時時間CYCTIME 返回結(jié)果
  • 調(diào)度參數(shù)配置：month=$[mm]
  • 處理調(diào)度參數(shù)返回值：SELECT CEIL(INT('${month}')/3);
  • 預(yù)期返回類型：正整數(shù)。
 20211025001700 4

獲取定時時間15分鐘前的年、月、日、小時、分鐘

使用調(diào)度參數(shù)獲取定時時間15分鐘前的年、月、日、小時、分鐘的配置及測試結(jié)果如下表。
參數(shù)配置 測試定時時間CYCTIME 返回結(jié)果
  • 調(diào)度參數(shù)配置：
    • year=$[yyyy-15/24/60]
    • month=$[yyyymm-15/24/60]
    • day=$[yyyymmdd-15/24/60]
    • hour=$[hh24-15/24/60]
    • mi=$[mi-15/24/60]
  • 處理調(diào)度參數(shù)返回值：select 'year=${year} month=${month} day=${day} hour=${hour} mi=${mi}';
  • 預(yù)期返回格式：
    • 年：yyyy
    • 月：yyyymm
    • 日：yyyymmdd
    • 小時：hh
    • 分鐘：mm
 20210727000500
  • year=2021
  • month=202107
  • day=20210726
  • hour=23
  • mi=50

獲取時間區(qū)間，調(diào)度間隔為1天

獲取昨天00:00:00到今天00:00:00的時間區(qū)間，調(diào)度間隔為1天。時間格式為yyyymmddhh24miss，精確到秒。
說明 使用Kafka和LogHub離線同步指定時間區(qū)間的數(shù)據(jù)時，如需配置調(diào)度參數(shù)，則調(diào)度參數(shù)的日期格式為yyyymmddhh24miss，日期區(qū)間為左閉右開。詳情請參見Kafka Reader和LogHub Reader。不同場景的數(shù)據(jù)增量同步，詳情請參見數(shù)據(jù)增量同步。
調(diào)度參數(shù)的配置及測試結(jié)果如下表。
參數(shù)配置 測試定時時間CYCTIME 返回結(jié)果
  • 調(diào)度參數(shù)配置：
    • beginDateTime=$[yyyymmdd-1]
    • endDateTime=$[yyyymmdd]
  • 處理調(diào)度參數(shù)返回值：select '${beginDateTime}000000 ${endDateTime}000000';
  • 預(yù)期返回格式：yyyymmddhh24miss
 20220117002300
  • 20220116000000
  • 20220117000000

獲取時間區(qū)間，調(diào)度間隔為1小時

獲取昨天00:00:00到今天00:00:00的時間區(qū)間，調(diào)度間隔為1小時。時間格式為yyyymmddhh24miss，精確到秒。
說明 使用Kafka和LogHub離線同步指定時間區(qū)間的數(shù)據(jù)時，如需配置調(diào)度參數(shù)，則調(diào)度參數(shù)的日期格式為yyyymmddhh24miss，日期區(qū)間為左閉右開。詳情請參見Kafka Reader和LogHub Reader。不同場景的數(shù)據(jù)增量同步，詳情請參見數(shù)據(jù)增量同步。
調(diào)度參數(shù)的配置及測試結(jié)果如下表。
參數(shù)配置 測試定時時間CYCTIME 返回結(jié)果
  • 調(diào)度參數(shù)配置：
    • beginDateTime=$[yyyymmddhh24-1/24]
    • endDateTime=$[yyyymmddhh24]
  • 處理調(diào)度參數(shù)返回值：select '${beginDateTime}0000 ${endDateTime}0000';
  • 預(yù)期返回格式：yyyymmddhh24miss
 20220117002300
  • 20220116230000
  • 20220117000000