WSO2流处理器:在http服务调用的http响应处理过程中的相关性

问题描述 投票:0回答:1

我有一个托管的http服务,接受趋势数据并返回一些输出。这个服务是用siddhi查询语言访问的,如下所示。

@sink(type='http-request', sink.id='trends', 
publisher.url='${SERVICE_URL}',  @map(type='json', @payload(""" {"trend":{{trendArray}} } """) ) )
define stream Request(item string, trendArray string);

@source(type='http-response' , sink.id='trends', http.status.code='200',
        @map(type='json', @attributes(stock = '<HOW_TO_GET_THIS_VALUE>', output = "<HOW_TO_GET_THIS_VALUE>")
) )
define stream Response(item string, output string);

http请求(和响应)的有效载荷不包括项目名称。

  1. 当响应到来时,我们希望分配项目名称,我们对输出进行打分--上面标记为HOW_TO_GET_THIS_VALUE。 如何在siddhi查询中实现这一点?
  2. 如何处理响应数据的as-is作为传递到字段?

我在siddhi中没有看到这种情况的描述。如果不支持的话,了解一下这种情况下的自定义扩展(基于http扩展)的细节会很好。为http调用添加代理层的解决方案不太理想。

wso2 siddhi
1个回答
0
投票

经过一些实验,HOW_TO_GET_THIS_VALUE='trp:item'。http sink应该也有这个字段,尽管它在payload中没有使用。

© www.soinside.com 2019 - 2024. All rights reserved.