Dataphin は、スケジューリング依存関係を使用してビジネスプロセス内のノードを順次実行し、データが適時かつ効果的に生成されるようにします。このトピックでは、周期的なオフラインパイプラインのスケジューリング依存関係を設定する方法について説明します。
操作手順
Dataphin ホームページで、上部のナビゲーションバーから [開発] > [データ統合] を選択します。
統合ページの上部メニューから、[Project] を選択します。(Dev-Prod モードの場合は、環境も選択する必要があります。)
左側のナビゲーションペインで、[オフライン統合] をクリックし、次に設定するオフラインパイプラインをクリックします。
右側のナビゲーションバーで [プロパティ] をクリックして [プロパティ] パネルを開きます。
[スケジューリングの依存関係] エリアで、統合タスクの [スケジューリングの依存関係] パラメーターを設定します。
上流依存関係
自動解析
統合タスクの上流の依存関係については、[自動解析] をクリックすると、Dataphin は自動的に統合タスクを解析し、上流タスクと出力テーブルを取得します。 解析が完了すると、取得されたすべての依存関係テーブルが上流依存関係リストに追加され、詳細の表示、編集、削除ができます。
説明入力テーブルに複数のソースタスクがある場合、既定ではすべてのソースタスクが上流依存関係として追加されます。
解析されたすべての依存関係の依存期間は、既定で 現在のサイクル となります。
ルートノードの追加
タスクに上流の依存関係がない場合は、[ルートノードを追加] をクリックして、ルートノードをその依存関係として設定します。
説明各テナントまたは企業は、virtual_root_node で始まる名前の仮想ルートノードで初期化されます。
このノードの前のサイクルを追加
これにより自己依存が作成され、現在のタスクインスタンスは前のインスタンス (たとえば、前日または前時間) の正常な完了に依存します。
依存関係の追加
[自動解析] でスケジューリング依存関係を解析できない場合や、[自動解析] で生成されたアップストリーム依存関係設定が実際のアプリケーションと一致しない場合は、手動で [+依存関係の追加] をクリックしてノードの アップストリーム依存関係 を追加できます。
依存関係の追加 - 物理ノード
ノードリストから1つ以上の物理ノードを選択します。このリストは、[現在のプロジェクト]、[プロジェクト]、[ノードタイプ]、[ノード名]、または [出力テーブル名] でフィルタリングできます。
依存関係の追加 - 論理テーブルノード
ノードリストから1つ以上の論理テーブルノードを選択します。このリストは、[論理テーブルタイプ]、[ビジネスカテゴリ]、および [論理テーブル名] でフィルタリングできます。
論理テーブル全体ではなく、特定のフィールドに依存するには、[依存フィールド] 列の
アイコンをクリックして、必要なフィールドを選択します。依存関係の追加 - クロステナントノード
ノードリストから1つ以上のクロステナントノードを選択します。このリストは、[テナント]、[ノードタイプ]、または [ノード名] でフィルタリングできます。
依存関係を追加すると、システムは 依存期間 と 依存ポリシー の推奨設定を自動的に適用します。特定の依存関係についてこれらの設定を変更するには、依存関係リストの
編集アイコンをクリックします。依存期間:上流タスクインスタンスのスケジュールされた実行の時間範囲です。通常、これは現在の日であり、時間範囲 [00:00, 24:00) に対応します。
依存関係ポリシー: 依存期間内に複数のインスタンスが存在する可能性があるため、依存関係ポリシーを指定する必要があります。 依存関係を満たすアップストリームタスクのステータスとして、[成功]、[失敗]、または [完了 (成功または失敗)] を選択します。 デフォルトは 成功 です。 デフォルトのクロスサイクル依存関係ポリシーの詳細については、「付録: デフォルトのクロスサイクル依存関係ポリシー」をご参照ください。
重要インスタンスが1つしかない場合、依存ポリシーは任意のオプションに設定できます。上流タスクのスケジューリング設定の変更に対応できるよう、相対パスポリシーのみがサポートされています。
成功:下流タスクを実行する前に、上流タスクが成功する必要があります。上流タスクが失敗した場合、下流タスクは実行されません。
失敗:下流タスクを実行する前に、上流タスクが最終的に失敗する (最後の自動再試行後に失敗する) 必要があります。上流タスクが成功した場合、下流タスクは実行されません。
完了 (成功または失敗):上流タスクが成功した、または最終的に失敗した (最後の自動再試行後に失敗した) 後に、下流タスクを実行できます。
このノードの出力
システムはノードの出力名を自動的に生成します。出力名を追加するには、[出力名を自動生成] をクリックします。
重要自動生成された出力名 を手動で変更しないでください。
[OK] をクリックしてスケジューリング依存関係の設定を完了します。
付録:既定のクロスサイクル依存ポリシー
現在のノードサイクル | 上流ノード | 上流ノードサイクル | 上流自己依存 | 既定の依存期間 |
月 | 現在のノード (自己依存) | - | 前のサイクル (前月) | |
週 | 現在のノード (自己依存) | - | 前のサイクル (前週) | |
日 | 現在のノード (自己依存) | - | 前のサイクル (1日前) | |
時間 | 現在のノード (自己依存) | - | 過去24時間 | |
分 | 現在のノード (自己依存) | - | 過去24時間 | |
日/週/月 | 現在のノード以外 | 日 | 現在の期間 (現在の日) | |
日/週/月 | 現在のノード以外 | 時間/分 | なし | 現在の期間 (現在の日) |
日/週/月 | 現在のノード以外 | 時間/分 | あり | 現在の期間 (現在の日) |
月/週/日/時間/分 | 現在のノード以外 | 月/週 | あり | 現在の期間 (現在の日) |
月/週/日/時間/分 | 現在のノード以外 | 月 | なし | 現在の期間 (現在の日) |
月/週/日/時間/分 | 現在のノード以外 | 週 | なし | 現在の期間 (現在の日) |
時間/分 | 現在のノード以外 | 日 | 現在の期間 (現在の日) | |
時間/分 | 現在のノード以外 | 時間/分 | 現在の期間 (現在の日) |