DataWorks:スケジューリングパラメーターの戻り値を後処理する典型的なシナリオ

パラメーター構成: 現在のタスクのスケジュールされた時間の年と月を取得するようにスケジューリングパラメーターを構成します。

last_month=$[yyyy-mm]

処理ロジック: ODPS SQL コードでは、まず当月の最初の日を構築します。次に、DATEADD 関数を使用して 1 日を減算し、前月の最終日を取得します。最後に、REPLACE 関数を使用して区切り文字を削除します。

SELECT REPLACE(DATEADD(date'${last_month}-01',-1,'dd'),'-','');

例: last_month パラメーターの値は 2025-07 です。関数が値を処理した後、返される結果は 20250630 です。

パラメーター構成: 月を取得するようにスケジューリングパラメーターを構成します。

month=$[mm]

処理ロジック: ODPS SQL コードでは、月を 3 で除算し、最も近い整数に切り上げて四半期を計算できます。

SELECT CEIL(CAST('${month}' AS INT)/3);

例: month パラメーターの値は 07 です。関数が値を処理した後、返される結果は 3 です。

パラメーター構成: スケジューリングパラメーターで算術演算 -15/24/60 を使用して、15 分前の年、月、日、時、分を直接取得します。

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]

処理ロジック: これらの事前計算されたパラメーターを SQL 文で直接参照できます。

select 'year=${year} month=${month} day=${day} hour=${hour} mi=${mi}';

例: 日をまたぐ計算の後、返される結果は year=2025 month=202507 day=20250726 hour=23 mi=50 です。

パラメーター構成: 昨日と今日の日付を取得します。

beginDateTime=$[yyyymmdd-1]

endDateTime=$[yyyymmdd]

処理ロジック: データフィルタリングの `WHERE` 句で、文字列を連結して時、分、秒の部分を完成させることができます。

event_time >= '${beginDateTime}000000' AND event_time < '${endDateTime}000000'

例: 返される結果の開始時刻は 20250726000000 で、終了時刻は 20250727000000 です。

パラメーター構成: 算術演算を使用して、前の時間と現在の時間を取得します。

beginDateTime=$[yyyymmddhh24-1/24]

endDateTime=$[yyyymmddhh24]

処理ロジック: データフィルタリングの `WHERE` 句で、文字列を連結して分と秒の部分を完成させることができます。

event_time >= '${beginDateTime}0000' AND event_time < '${endDateTime}0000'

例: 返される結果の開始時刻は 20250726230000 で、終了時刻は 20250727000000 です。