WSO2を使用して2つのクエリを結合するESB

Question

WSO2のESBで2つの異なるAPIを呼び出す方法を理解し、その結果を1つのレスポンスにまとめ、私は

<?xml version="1.0" encoding="UTF-8"?> 
<soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/" xmlns:soapenc="http://schemas.xmlsoap.org/soap/encoding/" xmlns:xsd="http://www.w3.org/2001/XMLSchema" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"> 
    <soapenv:Body> 
     <response xmlns="http://example.com/response"> 
      <query name="parts" xmlns="http://example.com/query"> 
       <row> 
        <id>1</id> 
        <part>Part 1.1</part> 
       </row> 
       <row> 
        <id>1</id> 
        <part>Part 1.2</part> 
       </row> 
       <row> 
        <id>1</id> 
        <part>Part 1.3</part> 
       </row> 
       <row> 
        <id>2</id> 
        <part>Part 2.1</part> 
       </row> 
       <row> 
        <id>2</id> 
        <part>Part 2.2</part> 
       </row> 
      </query> 
     </response> 
    </soapenv:Body> 
</soapenv:Envelope> 

：

http://example.com/items：

<?xml version="1.0" encoding="UTF-8"?> 
<soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/" xmlns:soapenc="http://schemas.xmlsoap.org/soap/encoding/" xmlns:xsd="http://www.w3.org/2001/XMLSchema" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"> 
    <soapenv:Body> 
     <response xmlns="http://example.com/response"> 
      <query name="items" xmlns="http://example.com/query"> 
       <row> 
        <id>1</id> 
        <name>Item 1</name> 
       </row> 
       <row> 
        <id>2</id> 
        <name>Item 2</name> 
       </row> 
      </query> 
     </response> 
    </soapenv:Body> 
</soapenv:Envelope> 

http://example.com/partsその最も基本的で、私は私はこのようなこと応答の何かに要求を作っている2つのバックエンドを持っています両方をリクエストして、その結果を組み合わせて次のように表示します：

<items> 
    <item> 
     <id>1</id> 
     <name>Item 1</name> 
     <parts> 
      <part> 
       <id>1</id> 
       <name>Part 1.1</name> 
      </part> 
      <part> 
       <id>1</id> 
       <name>Part 1.2</name> 
      </part> 
      <part> 
       <id>1</id> 
       <name>Part 1.3</name> 
      </part> 
     </parts> 
    </item> 
    <item> 
     <id>2</id> 
     <name>Item 2</name> 
     <parts> 
      <part> 
       <id>2</id> 
       <name>Part 2.1</name> 
      </part> 
      <part> 
       <id>2</id> 
       <name>Part 2.2</name> 
      </part> 
     </parts> 
    </item> 
</items> 

基本的に、両方のAPIからのすべての応答にはrowのリストがあり、それぞれにid要素が含まれています。 /itemsへの呼び出しのidは、その応答内で一意であり、partsの応答の各行は、/itemsの行に結びつくidを持っています。

<?xml version="1.0" encoding="UTF-8"?> 
<api context="/item_list" name="ItemList" xmlns="http://ws.apache.org/ns/synapse"> 
    <resource methods="POST" uri-template="/"> 
     <inSequence> 
      <header name="Content-Type" scope="transport" value="text/xml; charset=utf-8"/> 
      <clone> 
       <target> 
        <sequence> 
         <send> 
          <endpoint> 
           <address format="soap11" uri="http://example.com/items"/> 
          </endpoint> 
         </send> 
        </sequence> 
       </target> 
       <target> 
        <sequence> 
         <send> 
          <endpoint> 
           <address format="soap11" uri="http://example.com/parts"/> 
          </endpoint> 
         </send> 
        </sequence> 
       </target> 
      </clone> 
     </inSequence> 
     <outSequence> 
      <aggregate> 
       <correlateOn expression="//*[name()='response']/*[name()='query']/*[name()='row']/*[name()='id']" /> 
       <completeCondition> 
        <messageCount max="2" min="2"/> 
       </completeCondition> 
       <onComplete expression="//*[name()='response']/*[name()='query']/*[name()='row']"> 
        <send/> 
       </onComplete> 
      </aggregate> 
     </outSequence> 
     <faultSequence/> 
    </resource> 
</api> 

ここinSequenceが大きく簡略化され、それは2つの有効なクエリを送信し、期待応答を取り戻す：

私は、ESBで、次のAPIの定義を持っています。ここに記述されているoutSequenceは、クライアントに応答を送信したり、サーバーにエラーを記録したりすることはありません。 aggregateからcorrelateOn要素を削除した場合、2つのAPI呼び出しのうちの1つで、一見無作為に1つのrowが返されます。私はと思うcorrelateOn私がここで使用したいものですが、私はWSO2またはApacheから有用なドキュメントを見つけることができないので、私はそれを間違って使用していると確信しています。私のXPathの背景はかなり弱いので、表現にもいくつかの作業を使うことができると確信しています。

私はここでクローン/集約パターンで少なくとも正しいトラックにいますか？これらの2つのクエリの結果を私の例に似たものに組み合わせるにはどうすればよいですか？もし私が何かを近くでも得ることができれば、私はXSLTで残りをすることができるはずです。

Answer 1

このデモを見てみましょう：アイテムと

バックエンド1は応答：

<?xml version="1.0" encoding="UTF-8"?> 
<proxy xmlns="http://ws.apache.org/ns/synapse" 
     name="items" 
     transports="https http" 
     startOnLoad="true"> 
    <target> 
     <inSequence> 
     <payloadFactory media-type="xml"> 
      <format> 
       <soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/" 
           xmlns:xsd="http://www.w3.org/2001/XMLSchema" 
           xmlns:soapenc="http://schemas.xmlsoap.org/soap/encoding/" 
           xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"> 
        <soapenv:Body> 
        <response xmlns="http://example.com/response"> 
         <query xmlns="http://example.com/query" name="items"> 
          <row> 
           <id>1</id> 
           <name>Item 1</name> 
          </row> 
          <row> 
           <id>2</id> 
           <name>Item 2</name> 
          </row> 
         </query> 
        </response> 
        </soapenv:Body> 
       </soapenv:Envelope> 
      </format> 
      <args/> 
     </payloadFactory> 
     <log level="full"/> 
     <loopback/> 
     </inSequence> 
     <outSequence> 
     <send/> 
     </outSequence> 
     <faultSequence/> 
    </target> 
</proxy> 

をバックエンド2部で応答：

<?xml version="1.0" encoding="UTF-8"?> 
<proxy xmlns="http://ws.apache.org/ns/synapse" 
     name="parts" 
     transports="https http" 
     startOnLoad="true"> 
    <target> 
     <inSequence> 
     <payloadFactory media-type="xml"> 
      <format> 
       <soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/" 
           xmlns:xsd="http://www.w3.org/2001/XMLSchema" 
           xmlns:soapenc="http://schemas.xmlsoap.org/soap/encoding/" 
           xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"> 
        <soapenv:Body> 
        <response xmlns="http://example.com/response"> 
         <query xmlns="http://example.com/query" name="parts"> 
          <row> 
           <id>1</id> 
           <part>Part 1.1</part> 
          </row> 
          <row> 
           <id>1</id> 
           <part>Part 1.2</part> 
          </row> 
          <row> 
           <id>1</id> 
           <part>Part 1.3</part> 
          </row> 
          <row> 
           <id>2</id> 
           <part>Part 2.1</part> 
          </row> 
          <row> 
           <id>2</id> 
           <part>Part 2.2</part> 
          </row> 
         </query> 
        </response> 
        </soapenv:Body> 
       </soapenv:Envelope> 
      </format> 
      <args/> 
     </payloadFactory> 
     <log level="full"/> 
     <loopback/> 
     </inSequence> 
     <outSequence> 
     <send/> 
     </outSequence> 
     <faultSequence/> 
    </target> 
</proxy> 

私のAPIは、バックエンド1とバックエンドを呼び出します2とxsltで変換する：

<?xml version="1.0" encoding="UTF-8"?> 
<api xmlns="http://ws.apache.org/ns/synapse" 
    name="ItemList" 
    context="/item_list"> 
    <resource methods="POST" uri-template="/"> 
     <inSequence> 
     <header name="Action" scope="default" value="urn:mediate"/> 
     <call> 
      <endpoint> 
       <address uri="http://localhost:8283/services/items.itemsHttpSoap11Endpoint" 
         format="soap11"/> 
      </endpoint> 
     </call> 
     <enrich> 
      <source type="inline" clone="true"> 
       <Payloads/> 
      </source> 
      <target type="property" property="Items"/> 
     </enrich> 
     <enrich> 
      <source clone="true" xpath="$body/*"/> 
      <target action="child" xpath="$ctx:Items"/> 
     </enrich> 
     <payloadFactory media-type="xml"> 
      <format> 
       <soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/" 
           xmlns:xsd="http://www.w3.org/2001/XMLSchema" 
           xmlns:soapenc="http://schemas.xmlsoap.org/soap/encoding/" 
           xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"> 
        <soapenv:Body/> 
       </soapenv:Envelope> 
      </format> 
      <args/> 
     </payloadFactory> 
     <call> 
      <endpoint> 
       <address uri="http://localhost:8283/services/parts.partsHttpSoap11Endpoint" 
         format="soap11"/> 
      </endpoint> 
     </call> 
     <enrich> 
      <source clone="true" xpath="$body/*[name()='response']/*[name()='query']"/> 
      <target type="property" property="Parts"/> 
     </enrich> 
     <enrich> 
      <source type="property" clone="true" property="Parts"/> 
      <target action="child" xpath="$ctx:Items"/> 
     </enrich> 
     <enrich> 
      <source type="property" property="Items"/> 
      <target type="body"/> 
     </enrich> 
     <xslt key="transformTwoSourcesToOneResult"/>    
     <loopback/> 
     </inSequence> 
     <outSequence> 
     <send/> 
     </outSequence> 
     <faultSequence/> 
    </resource> 
</api> 

そして、私のXSLT変換：

<?xml version="1.0" encoding="UTF-8"?> 
<localEntry key="transformTwoSourcesToOneResult" xmlns="http://ws.apache.org/ns/synapse"> 
<xsl:stylesheet version="1.0" xmlns:xsl="http://www.w3.org/1999/XSL/Transform" 
           xmlns:ns0="http://example.com/query" 
           xmlns:ns1="http://example.com/response" 
           xmlns:xs="http://www.w3.org/2001/XMLSchema" 
           xmlns:exslt="http://exslt.org/common" 
           xmlns:saxon="http://saxon.sf.net/" 
           xmlns:syn="http://ws.apache.org/ns/synapse" 
           exclude-result-prefixes="ns0 ns1 xs"> 
    <xsl:output method="xml" encoding="UTF-8" indent="yes"/> 
    <xsl:template match="/"> 
    <xsl:variable name="var1_instance_Payloads" select="."/> 
     <items> 
      <xsl:for-each select="$var1_instance_Payloads/syn:Payloads"> 
       <xsl:variable name="var2_Payloads" select="."/> 
      <xsl:for-each select="$var2_Payloads/ns1:response/ns0:query/ns0:row"> 
       <xsl:variable name="var2_row" select="."/> 
       <item> 
        <id> 
         <xsl:value-of select="number(string($var2_row/ns0:id))"/> 
        </id> 
        <name> 
         <xsl:value-of select="string($var2_row/ns0:name)"/> 
        </name> 
        <parts> 
         <xsl:for-each select="$var2_Payloads/ns0:query/ns0:row"> 
          <xsl:variable name="var4_row" select="."/> 
          <xsl:if test="string((number(string($var2_row/ns0:id)) = number(string($var4_row/ns0:id)))) != 'false'"> 
           <part> 
            <id> 
             <xsl:value-of select="number(string($var4_row/ns0:id))"/> 
            </id> 
            <name> 
             <xsl:value-of select="string($var4_row/ns0:part)"/> 
            </name> 
           </part> 
          </xsl:if> 
         </xsl:for-each> 
        </parts> 
       </item> 
      </xsl:for-each> 
      </xsl:for-each> 
     </items> 
    </xsl:template> 
</xsl:stylesheet> 

</localEntry> 

APIレスポンス：

<items xmlns="http://ws.apache.org/ns/synapse" xmlns:syn="http://ws.apache.org/ns/synapse" xmlns:saxon="http://saxon.sf.net/" xmlns:exslt="http://exslt.org/common"> 
    <item> 
     <id>1</id> 
     <name>Item 1</name> 
     <parts> 
     <part> 
      <id>1</id> 
      <name>Part 1.1</name> 
     </part> 
     <part> 
      <id>1</id> 
      <name>Part 1.2</name> 
     </part> 
     <part> 
      <id>1</id> 
      <name>Part 1.3</name> 
     </part> 
     </parts> 
    </item> 
    <item> 
     <id>2</id> 
     <name>Item 2</name> 
     <parts> 
     <part> 
      <id>2</id> 
      <name>Part 2.1</name> 
     </part> 
     <part> 
      <id>2</id> 
      <name>Part 2.2</name> 
     </part> 
     </parts> 
    </item> 
</items>