1. Homepage
  2. Mule Runtime (4.3)
  3. Mule アプリケーションの開発
  4. コアコンポーネント

  5. Parallel For Each スコープ

Parallel For Each スコープ

Parallel For Each スコープにより、コレクションを同時処理に設定された制限のスコープ内で個別のルートで同時に処理される部分に分割することで、メッセージのコレクションを処理できます。すべてのメッセージが処理された後で、結果は分割前と同じ順序で集約され、その後もフローは続行されます。

考慮事項

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

  • 7.6 より前の Anypoint Studio バージョンでは、この機能は [Mule Palette (Mule パレット)] ビューでは提供されません。これらのバージョンで Parallel for Each を使用するには、XML で Parallel For Each スコープを手動で設定する必要があります。

Configuration (設定)

Parallel For Each スコープは次の項目から設定できます。

子要素 説明

Collection (コレクション) (​collection​)

並列で処理する部分のコレクションを定義する式を指定します。デフォルトでは、受信ペイロードを使用します。
属性 説明

Collection Expression (コレクション式) (​collection​)

コレクションを返す式。デフォルトでは、ペイロードは分割するコレクションとして扱われます。

Timeout (タイムアウト) (​timeout​)

各並列ルートのタイムアウトをミリ秒単位で指定します。デフォルトでは、タイムアウトはありません。

Max Concurrency (最大同時実行) (​maxConcurrency​)

ルーターが使用する並列性の最大レベルを指定します。デフォルトでは、すべてのルートが並列実行されます。

Target Variable (対象変数) (​target​)

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

Target Value (対象値) (​targetValue​)

操作の出力値に対して評価する式を指定します。この式の結果は対象変数に保存されます。デフォルトでは、これは操作の出力値と同じです。

例

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

<flow name="myFlow">

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

</flow>

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

1 つの要素の処理中に新しい変数を追加したり既存の変数を修正したりしても、別の要素の処理中は表示されません。これらのすべての変数の変更は Parallel For Each スコープ外で使用できないため、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 つのルートでエラーがスローされた場合、すべての処理が完了するまで、他のすべてのルートでは処理が続行されます。その後、ここで示しているように、すべての結果 (およびエラー) が集約されてから、​Error Handler​ によって処理されます。

<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 above 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 は各反復の出力メッセージのコレクションを出力します。

関連情報