无法在 Siddhi 中执行同步请求响应示例

Question

我正在尝试运行 WSO2 Siddhi 文档中的示例代码 given。

我已经复制了那里给出的内容。

@App:name("Http_Request_Response_Tutorial")
@App:description("This app demonstrate the usage of http request sink and http response source")

@source(type='http-response' ,sink.id='cardTypeSink',
@map(type='xml', namespaces = "xmlns=http://localhost/SmartPayments/",
@attributes(creditCardNo = 'trp:creditCardNo',creditCardType = ".")))
@sink(type='log')
define stream EnrichedCreditCardStream (creditCardNo string,creditCardType string);

@sink(type='http-request',publisher.url='https://secure.ftipgw.com/ArgoFire/validate.asmx/GetCardType',method='POST', headers="'Content-Type:application/x-www-form-urlencoded'",
sink.id="cardTypeSink",
@map(type='keyvalue', @payload(CardNumber='{{creditCardNo}}')))
define stream CreditCardStream (creditCardNo string);

在“事件模拟器”选项卡中，我传递了示例中给出的值：时间戳字段中的 154467847759 和 creditCardNo(STRING) 中的 555555555554444。

这是即将发生的错误。

[2019-05-22_14-59-14_632] ERROR {org.wso2.extension.siddhi.io.http.source.HttpResponseMessageListener} - No source of type 'http-response' for status code '500' has been defined. Hence dropping the response message. (Encoded)

Answer 1

根据错误，我认为你没有连接到 CreditCardStream 的流定义中的 publisher.url。

确保 CreditCardStream 在模拟事件之前连接到 https://secure.ftipgw.com/ArgoFire/validate.asmx/GetCardType。

如果连接成功，你会得到如下日志。

[2019-05-23 12:19:36,713]  INFO {org.wso2.extension.siddhi.io.http.sink.HttpSink} - Http_Request_Response_Tutorial:@sink( type = "http-request", publisher.url = "https://secure.ftipgw.com/ArgoFire/validate.asmx/GetCardType", method = "POST", headers = "'Content-Type:application/x-www-form-urlencoded'", sink.id = "cardTypeSink", @map( type = "keyvalue", @payload( CardNumber = "{{creditCardNo}}")))define stream CreditCardStream (creditCardNo string) has successfully connected to https://secure.ftipgw.com/ArgoFire/validate.asmx/GetCardType
[2019-05-23 12:19:55,597]  INFO {org.wso2.siddhi.core.stream.output.sink.LogSink} - Http_Request_Response_Tutorial : EnrichedCreditCardStream : [Event{timestamp=1558594195597, data=[5555555544444, ], isExpired=false}]

Answer 2

根据打印的错误，请求发送到 https://secure.ftipgw.com/ArgoFire/validate.asmx/GetCardType returns 500 响应。由于您没有 http-response 源来接受 500 个响应，响应负载将被丢弃。

您所观察到的行为在我们这边是不可重现的。本教程如所演示的那样正常工作。

下面是带有虚拟端点的教程示例的修订版本。你可以试试。

@App:name("Http_Request_Response_Tutorial")
@App:description("This app demonstrate the usage of http request sink and http response source")

@source(type='http-response' ,sink.id='cardTypeSink',
@map(type='xml', namespaces = "xmlns=http://localhost/SmartPayments/",
@attributes(creditCardNo = 'trp:creditCardNo',creditCardType = ".")))
@sink(type='log')
define stream EnrichedCreditCardStream (creditCardNo string,creditCardType string);

@sink(type='http-request',publisher.url='http://www.mocky.io/v2/5cee2fa1300000013a6e9961',method='POST', headers="'Content-Type:application/x-www-form-urlencoded'",
sink.id="cardTypeSink",
@map(type='keyvalue', @payload(CardNumber='{{creditCardNo}}')))
define stream CreditCardStream (creditCardNo string);

无法在 Siddhi 中执行同步请求响应示例

Not able to execute the Synchronous Request Response example in Siddhi

siddhi

sendasynchronousrequest

wso2sp