首页 文章

CEP Producer - 定时文件适配器

提问于
浏览
0

在Fiware CEP的User Manual(pdf),第12页中,它只是', that will retrieve events from a file at intervals of time based on their '时间', that will retrieve events from a file at intervals of time based on their '在我的下拉列表中只有生成类型的 生产环境 者:文件,JMS,休息和自定义 .

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

在手册中,OccurranceTime是以毫秒为单位,在创作工具中它具有可变类型的“日期”,因此“OccurranceTime”:“1000”应该是一秒 .

那么,我怎样才能在所需的时间制作活动?这只是正确格式化的问题吗?

(顺便说一句:在手册中,OccurranceTime以两种不同的方式拼写:'OccuranceTime'和'OccurranceTime' . 我认为正确的是双'r',因为它是创作新事件时创作工具默认提供的 . )

谢谢,亚瑟

1 回答

  • 1

    “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毫秒 .

相关问题