0

我正在构建一个微服务，其中我有一个主序列，它首先读取一个 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>$1</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": "$1",            
                                               "entityRecordId": "$2",            
                                               "data": {
                                                    "name":"$3",
                                                    "email":"$4"
                                                }
                                            }}
                            </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>

任何关于我做错了什么或任何可能有帮助的建议都将不胜感激！先感谢您！！

4

1 回答 1

1

根据文档，您需要在 Iterate 调解器内使用调用或发送调解器来继续消息流。

在 Iterate 中，您需要将拆分消息发送到端点以继续消息流。

对我来说，您似乎只是在转换消息有效负载。因此，您可以使用Foreach 调解器来做到这一点，而无需 Iterate 调解器。

于 2020-10-17T12:59:00.140 回答