DataWorks:スケジューリングパラメーター

以下のように、2 つのカスタム変数を使用して割り当てることができます：

• 日付：パラメーター datetime=$[yyyy-mm-dd]

• 時刻：パラメーター hour=$[hh24:mi:ss]

日付と時刻を別々に取得した後、コード内でスペースを使って pt=${datetime} ${hour} のように連結します。たとえば、SQL コードで select * from xc_demo_partition where dt='${key1} ${key2}'; を使用し、右側の [スケジュール設定] > [パラメーター] で key1=$[yyyymmdd] key2=$[hh24miss] を設定します。

スケジューリングパラメーターは、インスタンスのスケジュール時刻を使用します。スケジューリングパラメーターの置換値はインスタンスが生成されるときに決定され、実際の実行時刻によって変更されることはありません。したがって、スケジューリングパラメーターの値が変更されるかどうかを心配する必要はありません。[オペレーションセンター] > [定期インスタンス] ページで、[プロパティ] パネルの [スケジュール時刻] フィールドには、インスタンスの期待される実行時刻 (例：2021-07-13 00:00:00) が表示されます。これを [開始時刻] (例：00:00:27) と比較して確認できます。[Data Studio] ページで、[スケジュール設定] > [パラメーター] で var1=$bizdate var2=$cyctime var3=$[yyyymmdd] var4=$[yyyymmddhh24miss] を設定します。[スケジュール] を [日] に、[スケジュール時刻] を 00:00 に設定します。コードで select '${var1}' '${var2}'; を使用して、ビジネス日付とスケジュール時刻の値をそれぞれ確認します。

コードで変数を設定した後、編集ページの右側にある [スケジュール設定] をクリックし、パラメーターパネルで変数に値を割り当てます。スケジューリングパラメーターの詳細については、「スケジューリングパラメーターの設定」をご参照ください。たとえば、ODPS Spark ノードの [パラメーター] フィールドに $(var) を入力し、パラメーターテーブルにパラメーター名 var とパラメーター値 $bizdate の行を追加し、[パラメーターのプレビュー] をクリックして置換結果を確認します。

バッチ同期ノードなど一部のノードでは、パラメーターを設定してもスケジューリングパラメーターの戻り値を直接使用できません。これらのノードに対しては、対象ノードの上流ノードとして代入ノードを設定することができます。代入ノードはスケジューリングパラメーターを参照し、戻り値を処理・変換した後、ノードコンテキスト機能を通じて最終的なパラメーター値を下流の対象ノードに渡します。

• 代入ノードの設定の詳細については、「代入ノードの作成」をご参照ください。

• ノードコンテキストの設定の詳細については、「ノードコンテキストの設定」をご参照ください。

スケジューリングパラメーターはスケジューリングシステムによってのみ自動的に置換されるため、Data Studio でスケジューリングパラメーターの置換をテストしたい場合は、[開発環境でのスモークテストの実行] を使用できます。

解決策：

1. スケジューリングパラメーターに値が割り当てられているか確認してください。

2. 設定されたスケジューリングパラメーターが要件を満たしているか確認してください。詳細については、「スケジューリングパラメーターの設定」をご参照ください。

解決策：

1. 変数に値が割り当てられているか確認してください。

2. スケジューリングパラメーターに余分なスペースがないか確認してください。

3. ノード名では、ピリオド (.) と中国語文字を一緒に使用することはできません。

例： time①=②$[yyyymmdd③hh24:mi:ss]time1=$[yyyymmdd]④time2=$[hh24:mi:ss] (①②③④ はスペースの位置を示します)。

• スケジューリングパラメーターの等号 (=) の両側にスペースを入れることはできません。これは、例の ① と ② の位置に該当します。

• スケジューリングパラメーターの値にスペースはサポートされていません。これは、例の ③ の位置に該当します。

• 2 つのスケジューリングパラメーターは、1 つのスペースで区切る必要があります。これは、例の ④ の位置に該当します。

Data Studio でスケジューリングパラメーターを変更し、変更を送信してデプロイした場合、本番環境のオペレーションセンターで定期タスクのプロパティパネルを確認し、スケジューリングパラメーターが期待通りであるかを確認してください。期待通りでない場合は、タスクのデプロイメントページとデプロイメントパッケージを確認し、デプロイメントが成功したかを確認してください。特定のインスタンスのスケジューリングパラメーター置換を表示するには、定期インスタンスのプロパティパネルを確認します。

例：

• ノード A の当日定期インスタンス A1 のスケジューリングパラメーター time1 は $bizdate に設定されています。インスタンスは正常に実行され、コード内のパラメーター値は bizdate のビジネス日付 (特定の値) です。

• 日中のある時点で、スケジューリングパラメーター time1 が $bizdate から $cyctime に変更されます。すると、当日のインスタンスの実行パラメーターには cyctime のスケジュール時刻 (特定の値) が表示されます。

• 現在のインスタンスを再実行すると、最新のパラメーター設定である time1=$cyctime が使用されます。

• スケジューリングパラメーターが変更される前にインスタンスが使用したスケジューリングパラメーター置換を表示するには、ログを確認してください。詳細については、よくある質問：「ログを使用して実行中のインスタンスのパラメーター置換を確認する方法」をご参照ください。

[オペレーションセンター] > [定期インスタンス] ページで、インスタンスを選択し、下部の [プロパティ] パネルの [実行パラメーター] フィールドでスケジューリングパラメーターの実際の置換値 (例：var1=20210708233000 var2=20210709000000) を表示して、パラメーターが期待通りに更新されているかを確認します。

コード内で、キーワード SKYNET_PARAVALUE を探します。

07-09 00:00:19  INFO SKYNET_RERUN_MODE=1:
07-09 00:00:19  INFO SKYNET_FLOW_PARAVALUE=:
07-09 00:00:19  INFO SKYNET_ONDUTY=xxx:
07-09 00:00:19  INFO SKYNET_SYSTEMID=:
07-09 00:00:19  INFO CALC_ENGINE_IDENTIFIER=xxx:
07-09 00:00:19  INFO SKYNET_SOURCEID=xxx:
07-09 00:00:19  INFO SKYNET_PARAVALUE=var1=20210708233000 var2=20210709000000:
07-09 00:00:19  INFO SKYNET_TASKID=xxx:
07-09 00:00:19  INFO SKYNET_TENANT_ID=283789484710656:
07-09 00:00:19  INFO SKYNET_ID=700003341088:
07-09 00:00:19  INFO SKYNET_JOBID=700200619122:
07-09 00:00:19  INFO SKYNET_NODENAME=xc_partition_copy:
07-09 00:00:19  INFO SKYNET_CYCTYPE=0:
07-09 00:00:19  INFO SKYNET_DSC_JOB_VERSION=1:
07-09 00:00:19  INFO SKYNET_TASK_INPUT={}:
07-09 00:00:19  INFO SKYNET_FLOWNAME=ATCLOUD_FLOW:
07-09 00:00:19  INFO FILE_ID=700003341088:

夏時間 (DST) は、インスタンスの生成とパラメーターパーティションの計算でサポートされており、DST が開始および終了する日に正しい実行が保証されます。以下に米国太平洋時間を例として示します：

• DST が開始する日には、23 個のインスタンスが生成されます。その日の 03:00 の 10 分前にシフトすると 01:50 になります。DST が開始する日の 02:00 にスケジュールされたタスクはドライランされます。

• DST が終了する日には、24 個のインスタンスが生成されます。その日の 03:00 の 10 分前にシフトすると 02:50 になります。