聚合序列中的 OnComplete 未在迭代序列之后触发

Question

我正在构建一个微服务，其中有一个主序列，它首先读取一个 json 文件，然后进入迭代序列，该序列连接到具有 ID 的聚合器序列。这是主序列的顺序：

        <property expression="json-eval($)" name="ORIGINAL_PAYLOAD" scope="default" type="STRING"/>
        <sequence key="data-iterate-seq"/>
        <property name="aggregatedResponses" scope="default">
            <batch_response/>
        </property>
        <sequence key="data-aggregate-seq"/>

我面临的问题是，一旦它进入迭代，它首先触发 OnComplete 之外的聚合代码，然后返回并进行迭代，并且永远不会进入 OnComplete，也不会返回到主序。我设法使用 continueParent=true 使其继续主序列，但这样它永远不会进入聚合序列的 OnComplete。我也尝试将 onComplete 表达式切换到 $body/*[1] 和 //jsonObject 但它没有用编辑：<send/> 和 <loopback/> 运算符也没有。

这是我的迭代器

<?xml version="1.0" encoding="UTF-8"?>
<sequence name="data-iterate-seq" trace="disable" xmlns="http://ws.apache.org/ns/synapse">
    <iterate attachPath="json-eval($)" expression="json-eval($.records)" id="requestIterator" preservePayload="true">
        <target>
            <sequence>
                <payloadFactory media-type="json">
                    <format></format>
                    <args>
                        <arg evaluator="json" expression="$"/>
                    </args>
                </payloadFactory>
                <property name="messageType" scope="axis2" type="STRING" value="application/json"/>
                <log level="custom" separator="&#xa;">
                    <property expression="json-eval($)" name="BODY_INSIDE_ITERATE"/>
                </log>
                <!-- Prepare Payload -->
                <property expression="json-eval($.recordId)" name="recordId" scope="default" type="STRING"/>
                <property name="entitySetName" scope="default" type="STRING" value="accounts"/>
                <property expression="concat(get-property('msdynamics365.resource'),'/api/data/',get-property('msdynamics365.api.version'),'/')" name="patch-url" scope="axis2" type="STRING"/>
                <payloadFactory media-type="json">
                    <format>{"batch_response": "{ "relativeUrlTemplate": "{{apiUrl}}{{entitySetName}}{{entityRecordId}}",
                                               "method": "PATCH",            
                                               "entitySetName": "",            
                                               "entityRecordId": "",            
                                               "data": {
                                                    "name":"",
                                                    "email":""
                                                }
                                            }}
                            </format>
                    <args>
                        <arg evaluator="xml" expression="$ctx:entitySetName"/>
                        <arg evaluator="xml" expression="$ctx:recordId"/>
                        <arg evaluator="json" expression="$.data.name"/>
                        <arg evaluator="json" expression="$.data.emailaddress1"/>
                    </args>
                </payloadFactory>
                <property name="messageType" scope="axis2" type="STRING" value="application/json"/>
                <log level="full"/>
                <log level="custom" separator="&#xa;">
                    <property name="Results" value="Number of iterations"/>
                </log>
            </sequence>
        </target>
    </iterate>
</sequence>

和我的聚合器：

<?xml version="1.0" encoding="UTF-8"?>
<sequence name="data-aggregate-seq" onError="data-fault-seq" trace="disable" xmlns="http://ws.apache.org/ns/synapse">
    <aggregate id="requestIterator">
        <completeCondition>
            <messageCount max="-1" min="-1"/>
        </completeCondition>
        <onComplete aggregateElementType="root" enclosingElementProperty="aggregatedResponses" expression="json-eval($)" xmlns:ns="http://org.apache.synapse/xsd">
            <property expression="json-eval($)" name="aggregatedResponses" scope="default" type="STRING"/>
            <log level="full">
                <property expression="json-eval($)" name="OUT_SEQUENCE_AGGREGATED_RESPONSE"/>
            </log>
            <log level="full">
                <property expression="get-property('aggregatedResponses')" name="Responses"/>
            </log>
        </onComplete>
    </aggregate>
    <log level="custom">
        <property expression="json-eval($)" name="FINAL_PAYLOAD"/>
        <property expression="get-property('aggregatedResponses')" name="aggregated_Response"/>
    </log>
</sequence>

任何关于我做错了什么的建议或任何可能有帮助的事情都将不胜感激！提前致谢！！

Answer 1

根据documentation，您需要在Iterate mediator 内部使用call or send mediator 来继续消息流。

In Iterate you need to send the split messages to an endpoint to continue the message flow.

对我来说，您似乎只是在转换消息负载。因此，您可以使用 Foreach mediator 在没有 Iterate 中介的情况下执行此操作。

聚合序列中的 OnComplete 未在迭代序列之后触发

OnComplete in Aggregate sequence not triggered after the Iteration sequence

iterator

wso2

wso2esb

wso2ei

wso2mi