すべてのプロダクト
Search
ドキュメントセンター

DataWorks:異なるノードタイプに対するスケジューリングパラメーターの構成

最終更新日:Jan 11, 2025

共通のShellノードとPyODPSノードを除く他のタイプのノードのカスタム変数を定義し、スケジューリングパラメーターをカスタム変数に割り当てるには、ODPS SQLノードなどのSQLノードのスケジューリングパラメーターを構成するために使用される方法を参照できます。 特定の構成は、共通のShellノードとPyODPSノードでは異なります。 このトピックでは、さまざまなタイプのノードのスケジューリングパラメーターを構成する方法の例を示します。

SQLノードとバッチ同期ノード

スケジューリングパラメーターは、ほとんどのタイプのノードに適した方法を使用して、SQLノードとバッチ同期ノードに対して構成されます。 したがって、この方法を参照して、ほとんどのタイプのノードのスケジューリングパラメーターを構成できます。 このセクションでは、ODPS SQLノードを使用します。 このセクションでは、カスタムパラメーターをカスタム変数に割り当てる方法と、コード内でカスタム変数を参照する方法について説明します。

説明

一部のノードはスケジューリングパラメーターをサポートしていません。 ノードのタイプがスケジューリングパラメーターをサポートしているかどうかについては、ノードのタイプのドキュメントを参照してください。

Assign custom parameters to custom variables前の図では、カスタムパラメーターが [パラメーター] セクションのカスタム変数 var1、var2、var3、var4、および var5 に割り当てられ、カスタム変数がコードエディターで参照されています。 この例では、次の変数が定義されています。

  • var1: $bizdate を var1 として指定します。 この変数は、データのタイムスタンプを取得するために使用されます。 $bizdate は組み込みシステムパラメーターです。

  • var3: $cyctime を var3 として指定します。 この変数は、スケジューリング時刻を取得するために使用されます。 $cyctime は組み込みシステムパラメーターです。

  • var2: ${yyyymmdd} を var2 として指定します。 この変数は、データのタイムスタンプを取得するために使用されます。

  • var4: $[yyyymmddhh24:mi:ss] を var4 として指定します。 この変数は、スケジューリング時刻を取得するために使用されます。

  • var5: 定数 abc をこの変数に割り当てます。

スケジューリングパラメーターを構成および使用する方法の詳細については、「スケジューリングパラメーターの構成と使用」を参照してください。 カスタムパラメーターをカスタム変数に割り当てる方法の詳細については、「スケジューリングパラメーターのサポートされている形式」を参照してください。

PyODPSノード

コードの変更を避けるため、PyODPSノードでは、定義済みの変数を、コード内で ${param_name} 形式の文字列に置き換えることはできません。 ただし、コードを実行する前に、args という名前の辞書オブジェクトをグローバル変数に追加できます。 これにより、PyODPSノードは辞書オブジェクトからスケジューリングパラメーターの値を取得できます。 Configure scheduling parameters for a PyODPS node前の図では、カスタムパラメーターが [パラメーター] セクションのカスタム変数 var1、var2、および var3 に割り当てられ、args という名前の辞書オブジェクトが追加され、次にカスタム変数が args['var1']args['var2']、および args['var3'] の形式でコードエディターで参照されています。 この例では、次の変数が定義されています。

  • var1: $bizdate を var1 として指定します。 この変数は、データのタイムスタンプを取得するために使用されます。 $bizdate は組み込みシステムパラメーターです。

  • var2: ${yyyymmdd} を var2 として指定します。 この変数は、データのタイムスタンプを取得するために使用されます。

  • var3: $[yyyymmdd] を var3 として指定します。 この変数は、データのタイムスタンプを取得するために使用されます。

スケジューリングパラメーターを構成および使用する方法の詳細については、「スケジューリングパラメーターの構成と使用」を参照してください。 カスタムパラメーターをカスタム変数に割り当てる方法の詳細については、「スケジューリングパラメーターのサポートされている形式」を参照してください。

共通 Shellノード

共通 Shellノードのカスタム変数名をカスタマイズすることはできません。 変数は、$1$2$3 など、序数に基づいて名前を付ける必要があります。 パラメーターの数が 10 以上に達する場合は、${Number} を使用して超過変数を宣言します。 たとえば、${10} を使用して 10 番目の変数を宣言します。 Configure scheduling parameters for a common Shell node前の図では、カスタムパラメーターが [パラメーター] セクションのカスタム変数 $1、$2、および $3 に割り当てられ、カスタム変数がコードエディターで参照されています。 この例では、次の変数が定義されています。

説明

共通 Shellノードの場合、式を使用してのみカスタムパラメーターをカスタム変数に割り当てることができます。 複数カスタムパラメーターはスペースで区切ります。 カスタム変数が定義されているのと同じ順序で、カスタムパラメーターをカスタム変数に割り当ててください。 たとえば、[パラメーター] セクションに入力する最初のパラメーター $bizdate は、最初の変数 $1 に割り当てられます。

  • $1: $bizdate を $1 として指定します。 この変数は、データのタイムスタンプを取得するために使用されます。 $bizdate は組み込みシステムパラメーターです。

  • $2: ${yyyymmdd} を $2 として指定します。 この変数は、データのタイムスタンプを取得するために使用されます。

  • $3: $[yyyymmdd] を $3 として指定します。 この変数は、データのタイムスタンプを取得するために使用されます。

スケジューリングパラメーターを構成および使用する方法の詳細については、「スケジューリングパラメーターの構成と使用」を参照してください。 カスタムパラメーターをカスタム変数に割り当てる方法の詳細については、「スケジューリングパラメーターのサポートされている形式」を参照してください。

スケジューリングパラメーターの一般的な使用シナリオ

詳細については、「スケジューリングパラメーターの一般的な使用シナリオ」をご参照ください。