Joiun Redis元数据配置并在Siddhi中调用Http服务

问题描述

我有一个必须加入Redis配置的输入流。获得多个配置后，我将这些配置和输入流数据加入以调用Http Service发送SMS。但是我从来没有成功，任何人都有同样的问题吗？

@App:name("SmsTest")

@App:description("Publish http calls,receive their responses and process them")

define stream InputStream (Message string);

@Store(type='redis',table.name='AlertingListTable',nodes='10.68.140.208:6379',cluster.mode='false',@cache(size="100"))
@primaryKey('Name')
@index('Msisdn','Email')
define table AlertingListTable (Name string,Msisdn string,Email string);

@sink(type='http',on.error='log',sink.id='production-request',publisher.url='http://xx.xx.xx.xxx:xxxx/CRMBizServices/SMSService.serviceagent/SMSServicePortTypeEndpointHTTP',max.pool.active.connections = '100',min.pool.idle.connections = '100',exhausted.action = '2',headers="'SOAPAction:/CRMBizServices/SMSService.serviceagent/SMSServicePortTypeEndpointHTTP/sendSMS'",method='POST',@map(type='xml',@payload("""<soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/" xmlns:sms="http://www.fet.com.tw/ITSOA/CRM/SCHEMAS/SMSGService.xsd" xmlns:sch="http://www.fet.com.tw/ITSOA/schemas/Common-Domain/SharedResources/XSD/Base/Schema.xsd2">
   <soapenv:Header/>
   <soapenv:Body>
      <sms:SendSMSRq>
         <sms:authInfo>
            <!--You may enter the following 3 items in any order-->
            <!--Optional:-->
            <sch:channelID>NTF</sch:channelID>
            <sch:password>xxxxx</sch:password>
            <sch:userID>xxxxx</sch:userID>
         </sms:authInfo>
         <sms:smsPacket>
            <sms:MSISDN>{{Msisdn}}</sms:MSISDN>
            <sms:sysID>SMSG</sms:sysID>
            <sms:content>{{Message}}</sms:content>
            <!--Optional:-->
            <sms:lang>U</sms:lang>
            <sms:password>xxxxxx</sms:password>
         </sms:smsPacket>
         <sms:contactPacket>
            <sms:enableLog>true</sms:enableLog>
            <sms:logPayload>
               <sms:keyType>MSISDN</sms:keyType>
               <sms:keyId>{{Msisdn}}</sms:keyId>
               <sms:subject>SMS Test</sms:subject>
            </sms:logPayload>
         </sms:contactPacket>
      </sms:SendSMSRq>
   </soapenv:Body>
</soapenv:Envelope>""")))
define stream CallStream (Message string,Msisdn string);


@info(name='SendOutSms')
from InputStream as I join AlertingListTable as A
select I.Message,A.Msisdn
insert into CallStream;

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）

siddhi wso2