DataWorks:ブランチノードを使用した特定時刻のタスク実行

前提条件

開始する前に、以下を確認してください。

• DataStudio アクセス権を持つ DataWorks ワークスペース

• ノードを作成およびデプロイする権限

ステップ 1: ノードの依存関係の定義

以下のノード構造を設定します。

1. 代入ノード (ルート)：SKYNET_CYCTIME パラメーターを使用して、当日が月末であるかどうかを判断します。 月末である場合は 1 を、それ以外の場合は 0 を返します。 DataWorks はこの出力を取得し、ブランチノードに渡します。

2. [ブランチノード]: 代入ノードの出力に基づいて 2 つのブランチを定義します。

3. Shell ノード (2 つ): 1 つは月末ロジック用、もう 1 つはその他の日用です。それぞれが異なるブランチ上のブランチノードの子孫となります。

ステップ 2: 代入ノードの設定

代入ノードのコードは Python で記述されています。DataWorks は、標準出力の最終行 を outputs パラメーターの値として取得し、その後、ブランチノードがこれを読み取ります。

キャプチャルールは言語によって異なります。

スケジューリングプロパティを設定し、Python コードを貼り付けます。

ステップ 3: ブランチ条件の定義

ブランチ条件は Python 式です。各条件はブランチノードの特定の出力にリンクされています。条件が満たされると、その出力に依存する子孫ノードは期待どおりに実行され、他のすべての子孫ノードはドライランとなります。

スケジューリングプロパティとブランチ条件を設定します。

ブランチノードは、各条件に関連付けられた出力を生成します。

ステップ 4: Shell ノードと特定のブランチの関連付け

ブランチノードには 3 つの出力があります。各 Shell ノードの依存関係入力として、適切な出力を選択します。各出力は条件に結びついているため、慎重に選択してください。

• 毎月末日に実行される Shell ノードの依存関係:

  

• その他の日に実行される Shell ノードの依存関係:

  

ステップ 5: ブランチロジックのデプロイと検証

すべてのノードをコミットしてデプロイします。次に、データバックフィルを使用してブランチロジックをテストします。データバックフィルを使用すると、過去の日付を含む任意のスケジューリング時間をシミュレートできるため、ライブスケジューリングサイクルを待つことなく、各ブランチが正しく起動するかどうかを確認できます。

データタイムスタンプを **2018 年 12 月 30 日**と **2018 年 12 月 31 日**に設定します。これらは、それぞれ 2018 年 12 月 31 日と 2019 年 1 月 1 日のスケジューリング時間に対応します。

テストケース 1 — 月末ロジック (データタイムスタンプ: 2018 年 12 月 30 日 → スケジューリング時間: 2018 年 12 月 31 日)

ブランチノードは月末ブランチを選択します。

• 月末の Shell ノードは期待どおりに実行されます。

• その他の日の Shell ノードはドライランとなります。

テストケース 2 — 月末以外のロジック (データタイムスタンプ: 2018 年 12 月 31 日 → スケジューリング時間: 2019 年 1 月 1 日)

ブランチノードは月末以外のブランチを選択します。

• 月末の Shell ノードはドライランとなります。

• その他の日の Shell ノードは期待どおりに実行されます。