Siddhi的Web服务

Question

我有一个web服务(REST)。每次发生事件时，我都想给WS打电话。

我必须创建Siddhi的扩展并从java调用web服务？

如果我需要java来调用Web服务，应该扩展“聚合函数”吗？

在Siddhi中，有什么指令可以用来调用web服务？

下一个是我的WS示例：

http://72.37.125.125:3000/phishing?url=www.innerjoin.co

谢谢你的评论

Answer 1

您将能够使用HTTP publisher1实现此OOTB，而无需编写自定义代码。使用此发布服务器，您可以向具有自定义有效负载的预定义URL发送PUT/POST请求。如共享文档中所述，创建HTTP发布服务器。然后，您可以使用自定义json映射为您的web服务创建可接受的有效负载。在创建自定义映射时，可以引用大括号中的事件属性，如下所示。

{
   "payload_name_for_webservice":{{attribute_name_in_event}},
}

1

Answer 2

谢谢。

但我有个接收器和其他出版商。

当到达一个新事件时，我希望从siddhi调用WS到“org.wso2.vent.senor.stream:1.0.0”，web服务的输入参数是"meta_sensorName“。

我怎么能做到呢？

我的代码是：

/* Enter a unique ExecutionPlan */
@Plan:name('ExecutionPlan')

/* Enter a unique description for ExecutionPlan */
-- @Plan:description('ExecutionPlan')

/* define streams/tables and write queries here ... */

@Import('org.wso2.event.sensor.stream:1.0.0')
define stream sensorStream (meta_timestamp long, meta_isPowerSaverEnabled bool, meta_sensorId int, meta_sensorName string, correlation_longitude double, correlation_latitude double, humidity float, sensorValue double);