Application Integration でサポートされているコネクタをご覧ください。

For-Each Parallel タスク

For Each Parallel タスクを使用すると、メインの統合から他の統合（サブ統合）を実行できます。タスクの名前のとおり、サブ統合は並行して実行されます。

このタスクでは、API のトリガー ID を、実行する統合を識別するためのハンドルとして使用します。たとえば、API のトリガー ID を api_trigger/APITriggerX として指定した場合、タスクは api_trigger/APITriggerX トリガー ID を持つすべてのサブ統合を実行します。

サブ統合を実行した後、メイン統合でサブ統合のレスポンスを読み取ることもできます。このタスクを使用して、サブ統合をメイン統合の依存関係として実行します。

準備

For-Each Parallel タスクを構成する

For-Each Parallel タスクを構成するには:

  1. Google Cloud コンソールで [Application Integration] ページに移動します。

    Application Integration に移動

  2. ナビゲーション メニューで [統合] をクリックします。

    [統合] ページが開き、Google Cloud プロジェクトで使用可能なすべての統合が一覧表示されます。

  3. 既存の統合を選択するか、[統合の作成] をクリックして新しい統合を作成します。

    新しい統合を作成する場合:

    1. [統合の作成] ペインで名前と説明を入力します。
    2. 統合のリージョンを選択します。
    3. 統合用のサービス アカウントを選択します。統合のサービス アカウントの詳細は、統合ツールバーの [統合の概要] ペインでいつでも変更または更新できます。
    4. [作成] をクリックします。

    統合エディタで統合が開きます。

  4. 統合エディタのナビゲーション バーで、[タスク] をクリックして、使用可能なタスクとコネクタのリストを表示します。
  5. 統合エディタで [For Each Parallel] タスク要素をクリックして配置します。
  6. デザイナーの [For-Each Parallel] タスク要素をクリックして、[For-Each Parallel] タスク構成ペインを開きます。
  7. 次の表に示すように、表示された項目はタスクの構成プロパティを使用して設定します。

    プロパティへの変更は自動的に保存されます。

構成プロパティ

このセクションでは、For Each Parallelタスクの構成プロパティについて説明します。

入力プロパティ

プロパティ名 パラメータ名 データ型 説明
配列の選択 List to iterate String、Integer、Double、JSON 型の配列。 サブ統合を実行する必要がある値のリスト。リスト内の値ごとに別々のサブ統合スレッドが動作し、すべてのスレッドが並列で動作します。

[個々の配列要素をマッピングする場所] を設定することで、反復値をサブ統合に渡すこともできます。

また、[Add additional subintegration input(s)] フィールドでメインの統合からサブ統合に追加の値を渡すこともできます。
サブ統合の詳細 API Trigger ID String（文字列） 実行する公開済みサブ統合のトリガー ID。

この値は、サブ統合の API トリガーの [Trigger ID] フィールドで利用できます。
Execution strategy なし

SYNC: サブ統合を同期モードで実行します。このモードでは、メイン統合はサブ統合が完了するのを待ってから、ダウンストリーム タスクを続行します。

ASYNC: 非同期モードでサブ統合を実行します。このモードでは、メイン統合はサブ統合の完了を待ちません。サブ統合を呼び出した直後に、メイン統合がダウンストリームのタスクを実行します。
Run all integrations with this API Trigger ID 該当なし 同じ API のトリガー ID を持つすべての統合を実行します。

たとえば、統合 A と統合 B が同じ API トリガー IDを持っている場合、反復処理するリストの各項目で、統合 A と統合 B の両方が実行されます。

注: このオプションを選択すると、サブ統合のレスポンスはメイン統合で使用できなくなります。サブ統合のレスポンスを使用する場合は、[単一の統合を実行する] オプションを選択します。
Run a single integration 該当なし [統合名] フィールドで指定された統合のみを実行します。[サブ統合の出力から値を収集] セクションを構成することで、サブ統合からレスポンスを使用できます。
各実行時 Where to map individual array elements 文字列 配列要素をマッピングする必要があるサブ統合入力変数の名前。配列要素はサブ統合入力変数に直接マッピングできます。単一のサブ統合を選択した場合は、プルダウン リストからサブ統合の入力変数を選択できます。
Map to additional sub-integration input(s) 文字列 追加のサブ統合マッピング オプション。
  • Integration variable to map from: サブ統合の入力変数に渡される、現在の統合内の変数名。
  • Sub-integration input to map to: マッピング先のサブ統合入力変数の名前。

このフィールドでは、Key-Value ペアの形式の値を指定します。ここで、キーはメイン統合の変数で、値はサブ統合の対応する入力変数です。

たとえば、メイン統合に productID 変数があり、その変数を subIntProductID サブ統合変数にマッピングする場合を考えます。この場合、[Integration variable to map from] フィールドから productID を選択し、[Sub-integration input to map to] フィールドに subIntProductID を入力する必要があります。
Collect values from sub-integration output(s) 文字列 実行戦略が同期（SYNC）で、単一のサブ統合（単一統合を実行）が選択されている場合、サブ統合の出力は、現在の統合の配列変数に収集されます。
  • Sub-integration output to collect from: 集計されるサブ統合出力変数の名前。
  • Integration variable to collect into: 集計された出力を収集する現在の統合の変数名。
実行設定 Integrations to execute at a time (parallel) 整数 サブ統合で同時実行可能な最大数。デフォルト値は 50（最大 10000）です。

コホート内のすべてのサブ統合は、次のコホートのサブ統合の実行の前に完全に実行されます。
Ignore failures ブール値

次のいずれかの値を指定できます。

  • True: タスクはサブ統合の失敗を無視し、すべての実行を行います。
  • False: サブ統合が失敗した場合にタスクは失敗し、すべての実行を終了します。

ベスト プラクティス

並列処理タスクを使用する場合は、次のベスト プラクティスをおすすめします。

  • サブ統合による割り当て制限があれば、それに基づいてコホートサイズを設定します。
  • 後で使用できるようサブ統合の出力を収集する場合、SYNC 実行方法を使用します。
  • サブ統合が ASYNC以上実行される可能性がある場合、ASYNC 実行戦略を使用します。

For Each Parallel タスクに適用される使用量上限については、 使用量上限をご覧ください。

考慮事項

一般に、サブ統合の実行に 2 分以上かかる場合や、承認タスクなど、それ自体が非同期的なタスクに対して、SYNC実行方法を使用しないようにします。

エラー処理方法

タスクのエラー処理方法では、一時的なエラーによってタスクが失敗した場合のアクションを指定します。エラー処理方式と、さまざまな種類のエラー処理方式の詳細については、エラー処理方法をご覧ください。

割り当てと上限

割り当てと上限については、割り当てと上限をご覧ください。

次のステップ