mule : Scatter Gather : 如果我们在 Scatter gather 组件中设置目标变量，如何聚合来自不同路径的变量？

Question

使用 Mule 4，Scatter Gather 组件，我将目标变量设置为 "result"。我还有两个变量

firstVar : 在 Scatter Gather 组件外定义，但在一个路由内更新
secondVariable : 在 Scatter Gather 组件内部定义。

当我运行代码时，我希望在 Scatter Gather 完成时看到 firstVar（已更新）、secondVariable 和结果变量。但是我只看到有初始值的 firstVar。

观察：如果我删除目标变量结果，我会看到 firstVar（更新）、secondVariable 和聚合有效负载。

谁能解释一下我做错了什么？

参考代码：

<?xml version="1.0" encoding="UTF-8"?>

<mule xmlns:ee="http://www.mulesoft.org/schema/mule/ee/core"
    xmlns:http="http://www.mulesoft.org/schema/mule/http"
    xmlns="http://www.mulesoft.org/schema/mule/core"
    xmlns:doc="http://www.mulesoft.org/schema/mule/documentation"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://www.mulesoft.org/schema/mule/core http://www.mulesoft.org/schema/mule/core/current/mule.xsd
http://www.mulesoft.org/schema/mule/http http://www.mulesoft.org/schema/mule/http/current/mule-http.xsd
http://www.mulesoft.org/schema/mule/ee/core http://www.mulesoft.org/schema/mule/ee/core/current/mule-ee.xsd">
    <flow name="ScatterGather-ExampleFlow"
        doc:id="5dec6c32-4da7-4be0-91e1-26744e6e4761">
        <http:listener doc:name="Listener"
            doc:id="a75d1ddb-0481-45be-992d-39e397160257"
            config-ref="HTTP_Listener_config" path="/api/scattergather" />
        <logger level="INFO" doc:name="Logger"
            doc:id="9bb44a1f-287f-415c-b19f-87798797cfa8"
            message="Starting Scatter Gather Sample" />
        <set-variable value='#["First Value"]'
            doc:name="First Variable"
            doc:id="1eb7430b-f6a8-4366-8594-8f76479148ab" variableName="firstVar" />
        <scatter-gather doc:name="Scatter-Gather"
            doc:id="ef921649-8269-46ba-b38e-8e55f2694368" target="result">
            <route>
                <ee:transform doc:name="Transform Message"
                    doc:id="c5b2717c-5917-4641-aa4c-2283614cc4af">
                    <ee:message>
                        <ee:set-payload><![CDATA[%dw 2.0 output application/java 
            --- payload]]></ee:set-payload>
                    </ee:message>
                    <ee:variables>
                        <ee:set-variable variableName="firstVar"><![CDATA[%dw 2.0 output application/java --- 
            "updated First Value"]]></ee:set-variable>
                    </ee:variables>
                </ee:transform>
                <set-payload value='#["First route PAyload"]'
                    doc:name="Set Payload"
                    doc:id="8c479443-dd94-410e-9346-fedb7c0d3d71" />
            </route>
            <route>
                <set-variable value='"secondValue"'
                    doc:name="SecondVariable"
                    doc:id="6f78c3a7-ae00-4693-93ca-da98217d36d4"
                    variableName="secondVariable" />
                <set-payload value='#["2nd routePayload"]'
                    doc:name="Set Payload"
                    doc:id="aad2f059-2a35-4c29-85d7-45e33f317e59" />
            </route>
        </scatter-gather>
        <logger level="INFO" doc:name="Logger"
            doc:id="d03caeac-41e3-4dc9-8b67-de1da841011c" message="#[vars]" />
    </flow>
</mule>

Answer 1

我猜这与目标变量赋值被丢弃的事件有关。这可能是意料之中的。该事件包含 message/payload 和变量。使用 target 仅将生成的有效负载分配给变量。修改后的事件的其余部分将丢失。

我建议使用将所有需要的数据存储为附加属性的负载。您稍后可以使用 DataWeave 从其余的有效负载中提取属性。

Answer 2

在没有target变量的情况下，在所有处理路由执行完毕后，Scatter-Gather组件会创建一个新的Mule事件，将每个路由产生的所有Mule事件组合起来，然后将新的Mule事件传递给下一个组件流量。

如果使用 Scatter Gather ->General->target，那么它会将生成的有效负载（多个 mule 事件）填充到一个新的目标变量中，并保留原始 mule 事件及其变量。

mule : Scatter Gather : 如果我们在 Scatter gather 组件中设置目标变量，如何聚合来自不同路径的变量？

mule : Scatter Gather : How to aggregate variables from different routes if we are setting a target variable in the Scatter gather component?

mule

mule4