代码之家 › 专栏 › 技术社区 › A. Vieira

CEP Producer-定时文件适配器

complex-event-processing fiware

A. Vieira · 技术社区 · 10 年前

在Fiware CEP中 User Manual (pdf),第12页,其中提到您可以创建一个“Timed”类型的事件生成器,它将根据“OccuranceTime”属性每隔一段时间从文件中检索事件。在我的Fi实验室中,我在下拉列表中找不到这种“定时”类型的生产者,只有:文件、JMS、休息和自定义。

因此,我认为这个功能可以在“文件”类型中实现,但我无法让它工作,Producer中的属性“sendingDelay”始终决定读取速度,而不是事件负载中的“OccurrenceTime”。从Producer中删除“sendingDelay”使其根本不发送事件。

在手册中,OccurrenceTime被称为毫秒,而在创作工具中,它的变量类型为“日期”,因此“OccuranceTime”:“1000”应表示一秒。

那么,我如何才能在所需的时间制作事件?这仅仅是正确格式的问题吗?

(顺便说一句:在手册中,OccuranceTime有两种不同的拼写方式:“OccuranceTime”和“OccurrenceTime”。我相信正确的拼写是使用双“r”,因为这是创作工具在创建新事件时默认提供的。)

非常感谢。亚瑟

1 回复 | 直到 10 年前

Tal Haham 10 年前

“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毫秒发生。

推荐文章

Manolait · 固件错误:访问控制允许原点

8 年前

Kostas Tsakos · 使用IDAS固件设备管理器管理UDP数据包

8 年前

nacho tekniker · Fiware Lab:上下文代理实例磁盘空间

8 年前

LeonanCarvalho · 如何在Orion Context Broker NGSIv2上创建高级订阅表达式?

8 年前

Mr. Zacarias Satrustegui · Keyrock支持双因素身份验证

8 年前

JoseBenitez · 物联网代理LWM2M内存耗尽和生产环境

9 年前

Mario Corral · 如何使用cygnus将多个orion实体合并到一个ckan数据集?

10 年前

jccampos · Wilma pep代理和keystone-未找到有效的访问令牌

10 年前

A. Vieira · Cygnus未作为服务启动

10 年前

A. Vieira · CEP Producer-定时文件适配器

10 年前