CEP Producer - 定时文件适配器

CEP Producer - Timed file adapter

在 Fiware CEP 的 User Manual (pdf),第 12 页,提到您可以创建类型 'Timed' 的事件生产者,它将根据时间间隔从文件中检索事件他们 'OccurranceTime' 属性。 在我的 Fi-Lab 实例中,我没有在下拉列表中找到这种 'Timed' 类型的生产者,只有:文件、JMS、Rest 和自定义。

所以我认为这个功能可以在类型 'File' 中实现,但我无法让它工作,Producer 中的 属性 'sendingDelay' 总是指示读取速度,而不是事件负载中的 'OccurrenceTime'。从生产者中删除 'sendingDelay' 使其根本不发送事件。

OccurranceTime 在手册中说,以毫秒为单位,在创作工具中它的变量类型为 'Date',因此 "OccurranceTime":"1000" 应该表示一秒。

那么,我怎样才能让事件在需要的时间产生?只是格式正确的问题吗?

(顺便说一句:在手册中 OccurranceTime 有两种不同的拼写方式:'OccuranceTime' 和 'OccurranceTime'。我相信正确的拼法是双 'r',因为它是作者工具在创建新事件时默认给出。)

谢谢, 亚瑟

'Timed' 类型的事件生成器是 CEP 第 4 版中的一项新功能。它应该在 10 月在 FIWARE Lab 中可用。

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

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

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

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