1. Homepage
  2. Anypoint Code Builder

  3. Parallel For Each (<parallel-foreach/>)

Parallel For Each (<parallel-foreach/>)

logo cloud IDE Cloud IDE

logo desktop IDE Desktop IDE

コレクションを同時に処理される部分に分割して、メッセージのコレクションを処理します。

すべてのメッセージを処理した後で、このコンポーネントは分割前と同じ順序で結果を集約し、フローを続行します。

Parallel For Each では、すべての処理ルートの結果がリストにバッファされ、スコープの処理が終了した後にそのリストが返されます。これにより、大量のエントリを処理するときにメモリ不足エラーが発生する可能性があります。大きなペイロードを処理するには、代わりにバッチ処理を使用します。

コンポーネント XML

このコンポーネントは、次の XML 構造をサポートします。

<parallel-foreach
  doc:name="Parallel foreach"
  doc:id="tbfiiz"
  collection="#[payload]"
  timeout=30000
  maxConcurrency=15 />
<parallel-foreach/>​ Attributes 説明

doc:name

コンポーネントの編集可能な名前。

doc:id

コンポーネントの自動生成された識別子。

collection

コレクションを返す式。デフォルトは ​#[payload]​ です。

timeout

各並列ルートのタイムアウトをミリ秒単位で指定します。

maxConcurrency

ルーターが使用する並列性の最大レベルを指定します。

+ デフォルトでは、すべてのルートが並列実行されます。

target

処理されたペイロードを保存するために使用する変数を指定します。デフォルトでは、出力はフローのペイロードに保存されます。

+ デフォルトでは、Parallel For Each は出力をフローのペイロードに保存します。

targetValue

操作の出力値に対して評価する式を指定します。Parallel For Each は、この式の結果を ​target​ 変数に格納します。

+ デフォルトでは、これは操作の出力値と同じです。

例

次の例は、Parallel For Each を使用してコレクション内のすべての要素に文字列を追加する方法と、実行後の値に影響を与えずにスコープ内の変数を変更する方法を示しています。

例: 値の追加

次の例では、コレクション内のすべての要素に文字列​「-result」​を追加します。

<flow name="myFlow">

  <parallel-foreach collection="#[['apple', 'banana', 'orange']]">
      <set-payload value="#[payload ++ '-result']"/>
  </parallel-foreach>

</flow>

例: 変数の変更

次の例は、Parallel For Each スコープ内の既存の変数への変更は一時的なものであり、実行終了後には保持されないことを示しています。

<flow name="myFlow">

  <set-variable variableName="var1" value="var1"/>
  <set-variable variableName="var2" value="var2"/>
  <parallel-foreach collection="#[['apple', 'banana', 'orange']]">
      <choice>
          <when expression="#[payload == 'apple']">
              <set-variable variableName="var2" value="newValue"/>
              <set-variable variableName="var3" value="appleVal"/>
          </when>
          <when expression="#[payload == 'banana']">
              <set-variable variableName="var3" value="bananaVal"/>
          </when>
          <otherwise>
              <set-variable variableName="var3" value="otherVal"/>
              <set-variable variableName="var4" value="val4"/>
          </otherwise>
      </choice>
  </parallel-foreach>

</flow>

この例の出力は次のようになります。

{
      var1: "var1",
      var2: "var2"
}

Parallel For Each スコープのすべての実行は、ブロックの実行前と同じ変数および値で開始されます。

1 つの要素の処理中に新しい変数を追加したり既存の変数を修正したりしても、別の要素の処理中は表示されません。これらのすべての変数の変更は、Parallel For Each スコープの外部では使用できません。Parallel For Each スコープの実行後、一連の変数 (およびその値) は実行前と同じままになります。

エラー処理

このスコープはすべてのルートを並列処理するため、1 つのルートでエラーが発生した場合、すべての処理が完了するまで、他のすべてのルートでは処理が続行されます。その後、次の例に示すように、Parallel For Each はすべての結果 (およびエラー) を集約し、エラーハンドラーによって処理します。

<flow name="myFlow">

  <parallel-foreach collection="#[['banana', 'apple']]">
      <choice>
          <when expression="#[payload == 'banana']">
              <!-- Processor that throws error -->
          </when>
          <otherwise>
              <set-payload value="#[payload ++ '-result']"/>
          </otherwise>
      </choice>
  </parallel-foreach>
  <error-handler>
      <on-error-continue type="COMPOSITE_ROUTING">
          <!-- This will have the error thrown by the previous processor -->
          <logger message="#[error.errorMessage.payload.failures['0']]"/>
          <!-- This will be a null value -->
          <logger message="#[error.errorMessage.payload.failures['1']]"/>
          <!-- This will be a null value -->
          <logger message="#[error.errorMessage.payload.results['0']]"/>
          <!-- This will have the result of this (correctly executed) route -->
          <logger message="#[error.errorMessage.payload.results['1']]"/>
      </on-error-continue>
  </error-handler>

</flow>

スロー

  • MULE:COMPOSITE_ROUTING

For Each スコープと Parallel For Each スコープの違い

For Each と Parallel For Each のどちらも定義済みコレクションを分割し、スコープ内のコンポーネントがコレクションの各要素を処理します。どちらの場合も、同じ初期コンテキストで各ルートが実行されます。これらの 2 つのスコープの違いは、次のとおりです。

  • For Each は順次処理で、Parallel For Each は並列処理です。 この違いは​エラー処理​に影響します。

    処理の違いのため、For Each の実行はエラーの発生時に中断されてエラーハンドラーが呼び出されますが、Parallel For Each は ​MULE:COMPOSITE_ROUTE​ エラー種別でエラーハンドラーを呼び出す前にすべてのルートを処理します。

  • For Each はペイロードを変更しませんが、Parallel For Each は各反復の出力メッセージのコレクションを出力します。

関連情報