WSO2 EI 将一个端点响应的对象一个一个发送到另一个端点

Question

我是 WSO2 EI 的新手，我正在尝试从端点获取数据并将响应对象的每个对象发送到另一个端点。对于下一步，如果可以完成，我想向用户显示一个进度条以了解进程的执行情况。

在 github 和 Whosebug 上阅读和搜索 WSO2 文档和示例后，找不到任何完整的示例来展示如何完全执行此过程。

作为我使用 Integration Studio 完成的工作示例，这里有一个 API，它调用端点从服务器 1 获取数据，然后调用第二个端点将响应数据发送到服务器 2，它工作正常。

<?xml version="1.0" encoding="UTF-8"?>
<api context="/Product/UpdatePrice" name="ProductUpdatePrice" xmlns="http://ws.apache.org/ns/synapse">
    <resource methods="GET" url-mapping="/All">
        <inSequence>
            <call>
                <endpoint name="HTTPEndpoint">
                    <http method="get" uri-template="https://server1/api/Goods/GetPrices">
                        <suspendOnFailure>
                            <initialDuration>-1</initialDuration>
                            <progressionFactor>1</progressionFactor>
                        </suspendOnFailure>
                        <markForSuspension>
                            <retriesBeforeSuspension>0</retriesBeforeSuspension>
                        </markForSuspension>
                    </http>
                </endpoint>
            </call>
            <log level="custom">
                <property expression="json-eval($.message)" name="test"/>
            </log>
            <script language="nashornJs"><![CDATA[payload = mc.getPayloadJSON();
                var res = payload.response;
                mc.setPayloadJSON(res);]]></script>
            <call>
                <endpoint name="HTTPEndpoint">
                    <http method="post" uri-template="https://server2/api/Product/UpdateAllPrices">
                        <suspendOnFailure>
                            <initialDuration>-1</initialDuration>
                            <progressionFactor>1</progressionFactor>
                        </suspendOnFailure>
                        <markForSuspension>
                            <retriesBeforeSuspension>0</retriesBeforeSuspension>
                        </markForSuspension>
                    </http>
                </endpoint>
            </call>
            <respond/>
        </inSequence>
        <outSequence/>
        <faultSequence/>
    </resource>
</api>

在这个示例中，从 server1 响应的产品价格将发送到 server2 以更新那里的数据库。

我想要的是使用迭代调用server2API将server1响应的对象一个一个发送。

正如我在搜索中发现的那样，我似乎必须使用如下所示的迭代，但不知道我必须在示例中的哪个位置使用它。

    <iterate attachPath="json-eval($.categories)" expression="json-eval($.categories)" id="iterate-over-cats" preservePayload="true">
        <target>
            <sequence>
                <send>
                    <endpoint>
                        <http method="post" uri-template="https://server2/api/Product/UpdatePrice">
                            <suspendOnFailure>
                                <initialDuration>-1</initialDuration>
                                <progressionFactor>1</progressionFactor>
                            </suspendOnFailure>
                            <markForSuspension>
                                <retriesBeforeSuspension>0</retriesBeforeSuspension>
                            </markForSuspension>
                        </http>
                    </endpoint>
                </send>
            </sequence>
        </target>
    </iterate>

任何想法将不胜感激。

Answer 1

假设 Server1 returns 一个对象列表，您的解决方案已经使用建议的迭代器完成，您可以将它放在示例中当前调用的位置。根据您是否希望流程在迭代后继续，您将必须在它之后添加一个聚合中介。 [1] 我用调用替换了发送，否则迭代器响应将在 outSequence 中结束。

<?xml version="1.0" encoding="UTF-8"?>
<api context="/Product/UpdatePrice" name="ProductUpdatePrice" xmlns="http://ws.apache.org/ns/synapse">
    <resource methods="GET" url-mapping="/All">
        <inSequence>
            <call>
                <endpoint name="HTTPEndpoint">
                    <http method="get" uri-template="https://server1/api/Goods/GetPrices">
                        <suspendOnFailure>
                            <initialDuration>-1</initialDuration>
                            <progressionFactor>1</progressionFactor>
                        </suspendOnFailure>
                        <markForSuspension>
                            <retriesBeforeSuspension>0</retriesBeforeSuspension>
                        </markForSuspension>
                    </http>
                </endpoint>
            </call>
            <log level="custom">
                <property expression="json-eval($.message)" name="test"/>
            </log>
            <script language="nashornJs"><![CDATA[payload = mc.getPayloadJSON();
                var res = payload.response;
                mc.setPayloadJSON(res);]]></script>
       <iterate attachPath="json-eval($.categories)" expression="json-eval($.categories)" id="iterate-over-cats" preservePayload="true">
        <target>
            <sequence>
                <call>
                    <endpoint>
                        <http method="post" uri-template="https://server2/api/Product/UpdatePrice">
                            <suspendOnFailure>
                                <initialDuration>-1</initialDuration>
                                <progressionFactor>1</progressionFactor>
                            </suspendOnFailure>
                            <markForSuspension>
                                <retriesBeforeSuspension>0</retriesBeforeSuspension>
                            </markForSuspension>
                        </http>
                    </endpoint>
                </call>
            </sequence>
        </target>
    </iterate>
<!-- Basic aggregate here to correctly exit the iterate mediator --> 
            <respond/>
        </inSequence>
        <outSequence/>
        <faultSequence/>
    </resource>
</api>

[1]https://docs.wso2.com/display/EI660/Iterate+Mediator

WSO2 EI 将一个端点响应的对象一个一个发送到另一个端点

WSO2 EI send objects responded from an endpoint to another endpoint one by one

xml

api

esb

wso2

ei