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'

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

例：戻り値の開始時刻は 20250726230000、終了時刻は 20250727000000 です。