2

我编写了一个自定义的 http 接收器，它从另一个系统获取事件，json 示例如下：

{"tag":"A01","time":"10:01:00","value":"30.01"},
{"tag":"A01","time":"10:01:01","value":"35.01"},
{"tag":"A01","time":"10:01:02","value":"31.01"},
{"tag":"B01","time":"10:01:00","value":"105.017"},
{"tag":"B01","time":"10:01:01","value":"230.01"},
{"tag":"B01","time":"10:01:02","value":"117.01"}

接收者将json一一发送到包含字段的流名称“tag_input_stream”：

tag string, time string, value double

现在我有另一个流名称 format_tag_stream 其中包含字段：

time string, tag_A_val double, tag_B_val double

我想将值从 tag_input_stream 插入到 format_tag_stream 中，如下所示：

10:01:00, 30.01 , 105.017
10:01:01, 35.01 , 230.01
10:01:02, 31.01 , 117.01

我使用执行计划来编写 siddhi 脚本：

from every(e1=tag_input_stream)->e2=tag_input_stream[time==e1.time]
select e1.time as time, e1.value as v1, e2.value as v2
insert into format_tag_stream

但它不起作用。如何编写脚本，有什么例子吗？谢谢

4

1 回答 1

0

在查询中：

from every(e1=tag_input_stream[tag=='A01'])-> e2=tag_input_stream[time==e1.time AND tag=='B01']

您假设事件 A01 先出现，然后 B01 出现。但是，如果它们以相反的顺序出现，则不会执行上述查询。

因此，请编写如下所示的另一个查询，以应对逆序事件。

from every(e1=tag_input_stream[tag=='B01'])-> e2=tag_input_stream[time==e1.time AND tag=='A01']

谢谢，

上普尔

于 2016-05-12T07:10:27.120 回答