Hi, I'm Ask INFA!
What would you like to know?
ASK INFAPreview
Please to access Ask INFA.

目次

Search

  1. はじめに
  2. アプリケーション取り込みとレプリケーション

アプリケーション取り込みとレプリケーション

アプリケーション取り込みとレプリケーション

アプリケーション取り込みおよびレプリケーションタスクとデータ統合タスクフローの統合

アプリケーション取り込みおよびレプリケーションタスクとデータ統合タスクフローの統合

取り込まれたデータを処理および変換する
データ統合
タスクフローをトリガするように、
アプリケーション取り込みとレプリケーション
タスクを設定できます。この機能は、サポートされているソースタイプと、
Superpipe
オプションを使用しないSnowflakeターゲットを持つ、初期ロードタスクと増分ロードタスクで利用できます。
アプリケーション取り込みとレプリケーション
タスクを定義するときに、
[タスクフローで実行]
オプションを選択して、タスクを
データ統合
のタスクフローに追加できるようにすることができます。増分ロードジョブの場合は、必要に応じて
[サイクルIDの追加]
オプションを選択し、ターゲットテーブルにサイクルIDメタデータを含めることもできます。
データ統合
でタスクフローを設定するときに、タスクをイベントソースとして選択し、取り込まれたデータを変換する適切なトランスフォーメーションタイプを追加できます。
設定タスクフロー:
  1. データ取り込みおよびレプリケーション
    タスク設定ウィザードで、
    アプリケーション取り込みとレプリケーション
    タスクを定義する際に、次のオプションを選択します。
    • (オプション)
      [ターゲット]
      ページの
      [サイクルIDの追加]
      。増分ロードジョブの場合、このオプションを選択すると、各CDCサイクルに対して生成されたサイクルIDがターゲットテーブルに追加されます。
    • [スケジュールおよびランタイムオプション]
      ページの
      [タスクフローで実行]
      。このオプションにより、データ統合でタスクフローを定義するときにタスクを選択できるようになります。
  2. タスクの定義が完了したら、
    [保存]
    で保存します。
  3. データ統合
    でタスクフローを定義するには、ホームページの
    [調整]
    パネルをクリックします。
  4. タスクフローに
    アプリケーション取り込みとレプリケーション
    タスクを追加するには、次の手順を実行します。
    1. [タスクのプロパティ]で、
      [開始]
      をクリックします。
    2. [バインディング]
      フィールドで
      [イベント]
      を選択します。
    3. [イベントソース名]
      フィールドで、
      [選択]
      をクリックします。その後、
      [イベントソースの選択]
      ダイアログボックスで、
      データベース取り込みとレプリケーション
      タスクを選択して、
      [選択]
      をクリックします。
      タスクリストは、タスクタイプごとにフィルタリングできます。
    4. [イベントソース名]
      フィールドと
      [入力フィールド]
      にタスク名を表示されていることを確認します。例:
タスクフローは、初期ロードタスクが正常に完了したとき、または増分ロード操作の各CDCサイクルの後に開始するように自動的にトリガーされます。CDCサイクルが終了しても、前のタスクフローの実行がまだ実行中の場合、データはキューに入れられ、前のタスクフローが完了するまで待機します。