CEP生产者-定时文件适配器



在Fiware CEP的用户手册(pdf),第12页,它提到你可以创建一个类型为'Timed'的事件生成器,它将根据它们的' occurrence ' time '属性从文件中检索事件的时间间隔。在我的Fi-Lab实例中,我没有在下拉列表中找到这种"定时"类型的制作人,只有:File, JMS, Rest和Custom。

所以我认为这个功能可以在"File"类型中实现,但我不能让它工作,Producer中的属性"sendingDelay"总是决定读取速度,而不是事件有效载荷中的"cetime"。从Producer中删除'sendingDelay'会使它根本不发送事件。

在手册中说,以毫秒为单位,在创作工具中它的变量类型为"日期",所以"occurrence time":"1000"应该表示一秒。

那么,如何在期望的时间生成事件呢?这仅仅是正确格式化的问题吗?

(顺便说一句:在手册中,occurrence time有两种不同的拼写方式:' occurrence time '和' occurrence time '。我认为正确的是双'r',因为这是创作工具在创建新事件时默认提供的。

谢谢你,亚瑟

类型为'Timed'的事件生成器是CEP第4版的一个新特性。它应该可以在10月在FIWARE实验室使用。

可用时,您可以在CEP创作工具中选择它作为制作人的类型。然后,CEP将从输入文件中读取事件。在这个文件中,您将写入每个事件的预期发生时间。

例如,如果JSON格式的输入事件文件的内容为:

{"Name":"TrafficReport", "volume":"1000", "OccurrenceTime":"1000"}
{"Name":"TrafficReport", "volume":"1600", "OccurrenceTime":"6000"}
{"Name":"TrafficReport", "volume":"2500", "OccurrenceTime":"11000"}

生产者将在第一个输入事件后5秒处理第二个输入事件,因为它说在第一个输入事件发生后5000毫秒。

最新更新