如何使用另一个接收器类型为“ http-response”的流的响应来更新流]] << [

Question

我正在尝试通过附加属性来丰富我的输入流，该属性通过“ http-response”响应接收器填充。

[我尝试使用带有窗口属性的“ join”和带有“ every”关键字来合并两个流，并将合并后的流插入另一个流以丰富它。

当传入事件以1秒或更长的固定间隔进入时，窗口属性（window.time（1秒）或window.length（1））和“每个”关键字都可以很好地工作。

[同时（例如10或100）事件在同一时间（在一秒钟之内）发送。然后合并的结果不是预期的。

具有“窗口”属性的人（加入）

**

from EventInputStreamOne#window.time(1 sec) as i
        join EventInputStreamTwo as s
        on i.variable2 == s.variable2
select i.variable1 as variable1, i.variable2 as variable2, s.variable2 as variable2
insert into EventOutputStream;

**

带有“ every”关键字的那个

**

from every e1=EventInputStream,e2=EventResponseStream
select e1.variable1 as variable1, e1.variable2 as variable2, e2.variable3 as variable3
insert into EventOutputStream;

**

是否有更好的方法来合并两个流以更新第三个流？

正在尝试通过附加属性来丰富我的输入流，该属性通过“ http-response”响应接收器填充。我尝试使用带有窗口属性和“每个”关键字的“ join” ...

Answer 1

要获取原始请求属性，可以按如下方式使用自定义映射，