WSO2 ESB无后端调用下迭代聚合及异常处理问题求助

针对你遇到的遍历数据库记录更新、聚合结果发邮件（需包含成功/失败记录）的场景，以下是两种可行的解决方案：

方案一：ForEach + Try-Catch + Enrich（推荐） #

这个方案避开了自动聚合的限制，在每条记录的处理流程内捕获异常，直接将结果聚合到上下文属性中，全程可控。

实施步骤： #

1. 初始化聚合容器：提前创建一个XML结构的属性，用来存储成功和失败记录。
2. 遍历数据库记录：用ForEach mediator循环处理每条记录，内部用Try-Catch包裹业务逻辑，确保单条记录失败不中断整个循环。
3. 聚合结果：成功记录写入<successes>节点，失败记录（附带错误信息）写入<failures>节点。
4. 生成邮件并发送：循环结束后，从聚合属性中提取数据，生成邮件内容并发送。

配置示例： #

<!-- 初始化聚合容器，存储成功/失败记录 -->
<property name="aggregatedResults" scope="default" type="OM">
  <results>
    <successes/>
    <failures/>
  </results>
</property>

<!-- 遍历数据库返回的记录节点 -->
<foreach expression="//dbRecords/record" id="recordProcessingLoop">
  <sequence>
    <try>
      <!-- 这里替换为你的数据库更新逻辑（比如用Script mediator操作本地数据库） -->
      <script language="js">
        var record = mc.getPayloadXML();
        var recordId = record.getAttribute('id');
        // 模拟更新成功，添加状态标记
        record.setAttribute('status', 'success');
        record.setAttribute('updatedAt', new Date().toISOString());
      </script>
      <!-- 将成功记录追加到聚合容器的successes节点 -->
      <enrich>
        <source type="body" clone="true"/>
        <target type="property" property="aggregatedResults" action="child" xpath="//results/successes"/>
      </enrich>
    </try>
    <catch>
      <!-- 捕获异常，标记失败并添加错误信息 -->
      <script language="js">
        var record = mc.getPayloadXML();
        var errorMsg = mc.getProperty('ERROR_MESSAGE');
        record.setAttribute('status', 'failed');
        record.appendChild(new XML('<errorDetails>' + errorMsg + '</errorDetails>'));
      </script>
      <!-- 将失败记录追加到聚合容器的failures节点 -->
      <enrich>
        <source type="body" clone="true"/>
        <target type="property" property="aggregatedResults" action="child" xpath="//results/failures"/>
      </enrich>
    </catch>
  </sequence>
</foreach>

<!-- 生成邮件内容，统计成功/失败数量并嵌入记录 -->
<payloadFactory media-type="xml">
  <format>
    <emailContent>
      <title>数据库记录更新通知</title>
      <summary>成功更新$1条，失败$2条</summary>
      <successfulRecords>$3</successfulRecords>
      <failedRecords>$4</failedRecords>
    </emailContent>
  </format>
  <args>
    <arg evaluator="xpath" expression="count(get-property('aggregatedResults')//successes/record)"/>
    <arg evaluator="xpath" expression="count(get-property('aggregatedResults')//failures/record)"/>
    <arg evaluator="xml" expression="get-property('aggregatedResults')//successes"/>
    <arg evaluator="xml" expression="get-property('aggregatedResults')//failures"/>
  </args>
</payloadFactory>

<!-- 发送邮件，替换为你的邮件端点配置 -->
<send>
  <endpoint>
    <address uri="mailto:target@example.com?subject=数据库更新结果通知"/>
  </endpoint>
</send>

方案优势： #

• 单条记录失败不会终止整个遍历流程，所有结果都会被聚合。
• 聚合过程完全可控，不需要依赖ESB的自动分片聚合逻辑，避免异常场景下无法获取聚合结果的问题。

方案二：Iterate + Aggregate（适配原有思路） #

如果你坚持使用Iterate+Aggregate，可以通过手动触发聚合的方式解决循环无法终止的问题：

1. 配置Iterate时设置continueParent="true"：让父序列继续执行，不等待Iterate的子序列全部完成。
2. 在子序列中处理记录并标记进度：每条记录处理完成后，用属性记录已处理的数量，同时将结果片段Enrich到父序列的聚合节点中。
3. 手动触发聚合：在父序列中添加Script mediator，检查已处理数量是否等于总记录数，满足条件时调用Aggregate mediator的complete属性触发聚合。
4. 异常处理：在子序列的OnError中标记失败记录，同样Enrich到聚合节点，确保失败记录被纳入聚合。

关键配置要点： #

<!-- 初始化总记录数 -->
<property name="totalRecords" evaluator="xpath" expression="count(//dbRecords/record)" scope="default"/>
<property name="processedCount" value="0" scope="default" type="INTEGER"/>

<!-- 配置Iterate，允许父序列继续执行 -->
<iterate continueParent="true" attachPath="//dbRecords/record" id="recordIterate" sequential="true">
  <sequence>
    <try>
      <!-- 处理记录更新逻辑 -->
      <script language="js">
        // 模拟更新成功
        var record = mc.getPayloadXML();
        record.setAttribute('status', 'success');
      </script>
      <!-- 将成功片段Enrich到父序列的聚合容器 -->
      <enrich>
        <source type="body" clone="true"/>
        <target type="parent" action="child" xpath="//aggregationContainer/successes"/>
      </enrich>
    </try>
    <catch>
      <!-- 处理失败逻辑，Enrich到父序列的失败节点 -->
      <script language="js">
        var record = mc.getPayloadXML();
        record.setAttribute('status', 'failed');
        record.appendChild(new XML('<error>' + mc.getProperty('ERROR_MESSAGE') + '</error>'));
      </script>
      <enrich>
        <source type="body" clone="true"/>
        <target type="parent" action="child" xpath="//aggregationContainer/failures"/>
      </enrich>
    </catch>
    <!-- 更新已处理计数 -->
    <script language="js">
      var count = parseInt(mc.getProperty('processedCount')) + 1;
      mc.setProperty('processedCount', count.toString());
    </script>
  </sequence>
</iterate>

<!-- 检查是否所有记录处理完成，触发聚合 -->
<script language="js">
  var total = parseInt(mc.getProperty('totalRecords'));
  var processed = parseInt(mc.getProperty('processedCount'));
  if (processed === total) {
    mc.setProperty('triggerAggregate', 'true');
  }
</script>

<!-- 触发聚合 -->
<aggregate id="recordIterate" completeCondition="get-property('triggerAggregate') = 'true'">
  <onComplete enclosingElementProperty="aggregationContainer">
    <!-- 聚合完成后生成邮件并发送 -->
    <payloadFactory media-type="xml">
      <!-- 邮件内容模板 -->
    </payloadFactory>
    <send>
      <!-- 邮件端点 -->
    </send>
  </onComplete>
</aggregate>

注意事项： #

• 必须设置sequential="true"确保记录按顺序处理，计数准确。
• 聚合的completeCondition要依赖手动设置的触发属性，避免无法触发聚合的问题。

内容的提问来源于stack exchange，提问作者Kavindi Vidushani