FTP チェックノードは、FTP プロトコルを用いて定期的に特定のファイルの存在を確認します。ファイルが検出された場合、ノードは後続ノードをトリガーします。ファイルが検出されない場合は、停止条件を満たすまで再試行を繰り返します。このノードは、DataWorks と外部スケジューリングシステム間で信号をやり取りする際に一般的に使用されます。
注意事項
DataStudio(クラシック)では、**FTP チェックノードの使用は推奨されていません**。**直ちにチェックノードへの移行**をお勧めします。詳細については、「チェックノード」をご参照ください。
DataStudio(新規)では、FTP チェックノードは**サポートされていません**。
前提条件
FTP データソースが作成済みであること。注:ノードは、キー 認証を使用する
SFTP構成をサポートしません。ワークフローが作成済みであること。詳細については、「自動実行型ワークフローの作成」をご参照ください。
背景情報
利用シーン:DataWorks のタスクが、外部システムによって書き込まれるデータに依存している場合です。DataWorks は、外部の書き込みタスクの完了をネイティブに検知できません。完了を通知するために、外部システムがマーカーファイル(例: .done ファイル)を作成します。FTP チェックノードは、この .done ファイルを定期的にポーリングし、検出された時点で後続ノードをトリガーします。
マーカーファイルのファイルシステムは、外部スケジューリングシステムが決定します。
本トピックでは
.doneファイルを例として説明していますが、ファイル名は任意にカスタマイズできます。
処理の流れは以下のとおりです:
外部データが準備完了した時点で、外部システムがマーカーファイル(例:
xxxx2021-03-03.done)を生成します。本トピックでは、.doneサフィックスを持つファイルをマーカーファイルとして扱います。ビジネス要件に応じて、マーカーファイルをカスタマイズできます。FTP データソースが、ファイルシステムからマーカーファイルを読み取ります。
FTP チェックノードが、チェック戦略に基づきデータソースに対してマーカーファイルの存在をポーリングします。
検出された場合:ノードは成功を返し、後続ノードをトリガーします。
検出されなかった場合:ノードは設定された戦略に従って再試行を繰り返し、上限に達するまで継続します。
FTP チェックノードのチェック戦略について詳しくは、「検出対象およびチェック戦略の設定」セクションをご参照ください。
FTP チェックノードが成功を返した場合のみ、後続ノードが実行されます。
成功時:後続ノードが外部データベースへのアクセスを開始します。
失敗時:後続ノードは外部データベースへのアクセスを開始しません。
後続ノードが外部データベース内のデータにアクセスします。
外部データベースには、Oracle、MySQL、SQL Server などのデータベースまたはストレージサービスが含まれますが、これらに限定されません。
制限事項
リソースグループ:FTP チェックノードは、サーバーレスリソースグループ(推奨)または従来の専用リソースグループでのスケジューリングをサポートしています。サーバーレスリソースグループの購入および利用方法については、「サーバーレスリソースグループの利用」をご参照ください。
データソース:「FTP データソース」のうち、
SFTPプロトコルと キー 認証を使用する構成はサポートされていません。分単位または時単位のスケジューリングサイクルでは、**チェック停止戦略**として チェック停止時刻 を選択できません。チェック停止回数 をご使用ください。
サポートされるリージョン:中国 (杭州)、中国 (上海)、中国 (北京)、中国 (深セン)、中国 (成都)、中国 (香港)、日本 (東京)、シンガポール、マレーシア (クアラルンプール)、インドネシア (ジャカルタ)、ドイツ (フランクフルト)、イギリス (ロンドン)、米国 (シリコンバレー)、米国 (バージニア)。
FTP チェックノードの作成
DataWorks コンソールにログインします。
DataStudio に移動します。
アイコンにカーソルを合わせ、 を選択します。あるいは、目的のワークフローを開き、一般 を右クリックして、 を選択することもできます。
ノードの作成 ダイアログボックスで、名前 を入力し、対象フォルダー を選択します。
説明ノード名には、英字、漢字、数字、アンダースコア (_)、ピリオド (.) を使用できます。文字数は最大 128 文字までです。
- 確認 をクリックします。
右ペインで プロパティ をクリックし、スケジューリングを設定します。
スケジューリングプロパティには、基本プロパティ、時間プロパティ、リソースプロパティ、依存関係 が含まれます。詳細については、「基本プロパティの設定」、「時間プロパティの設定」、「リソースプロパティの設定」、「同一サイクルスケジューリングの依存関係の設定」をご参照ください。
検出対象およびチェック戦略を設定します。

FTP データソースの選択 リストから、対象のデータソースを選択します。
FTP または SFTP データソースを選択できます。利用可能なデータソースがない場合は、新たに作成してください。詳細については、「FTP データソースの追加」をご参照ください。
チェックファイル フィールドに、ファイルパスを入力します。パスが動的な場合は、スケジューリングパラメーターを使用して可変パスを設定できます。詳細については、「スケジューリングパラメーターのサポート形式」をご参照ください。
チェック間隔 (秒) フィールドで、ポーリング間隔を設定します。
チェック停止戦略 セクションで、チェックを停止するための戦略を設定します。
チェック停止時刻:カットオフ時刻(フォーマット:
hh24:mi:ss)。この時刻までにファイルが検出されない場合、タスクは失敗します。ファイルが検出された場合は、後続ノードがトリガーされます。説明FTP チェックノード のスケジューリングサイクル設定により、利用可能なチェック停止戦略が異なります:
スケジューリングサイクルが 分 または 時 に設定されている場合、チェック停止時刻 はサポートされていません。必ず チェック停止回数 をご使用ください。詳細については、「FTP チェック戦略の設定」をご参照ください。
スケジューリングサイクルを 日 から 分 または 時 に変更した場合、チェック停止時刻 戦略は無効になります。ノードをコミットするには、戦略を チェック停止回数 に変更する必要があります。
チェック停止回数:ポーリング試行の最大回数。この回数を超えてファイルが検出されない場合、タスクは失敗します。
保存およびコミットを行います。
説明ノードをコミットするには、あらかじめ 再実行 および 上流依存関係 のプロパティを設定する必要があります。
ツールバーの
アイコンをクリックして、ノードを保存します。ツールバーの
アイコンをクリックします。新バージョンの送信 ダイアログボックスで、変更内容の説明 を入力します。
確認 をクリックします。
標準モードのワークスペースでは、コミット後に 公開 をクリックします。詳細については、「タスクの公開」をご参照ください。
- ノードの運用・保守(O&M)操作を実行します。詳細については、「自動実行型ノードの基本 O&M 操作」をご参照ください。