公开(公告)号：CN104778042A

公开(公告)日：2015-07-15

申请号：CN201510146187.0

申请日：2015-03-30

Applicant: 江苏省邮电规划设计院有限责任公司

Inventor： 田闯 ,  袁伟伟 ,  冒兵 ,  朱磊 ,  李卫 ,  张萍

IPC: G06F9/44

Abstract: 本发明公开了一种基于事件流处理和插件式开发框架的流数据处理方法，包括：步骤1，创建插件宿主程序；步骤2，定义插件宿主程序与插件之间的接口规范；步骤3，针对不同的外场感知设备的数据采集协议生成相对应的数据采集插件；步骤4，创建事件流处理引擎；步骤5，为事件流处理引擎定义时间窗口或长度窗口；步骤6，针对不同的外场感知设备的数据采集协议实现相对应的数据处理规则；步骤7，定义并注册事件；步骤8，将注册的事件分别与步骤6中实现的各种数据处理规则相关联；步骤9，设置事件处理条件；步骤10，创建源数据队列以及目标队列；步骤11，创建消费线程；步骤12，将目标数据导出到目的地；步骤13，创建守护进程。

公开(公告)号：CN104778042B

公开(公告)日：2017-09-19

申请号：CN201510146187.0

申请日：2015-03-30

Applicant: 江苏省邮电规划设计院有限责任公司

Inventor： 田闯 ,  袁伟伟 ,  冒兵 ,  朱磊 ,  李卫 ,  张萍

IPC: G06F9/44

Abstract: 本发明公开了一种基于事件流处理和插件式开发框架的流数据处理方法，包括：步骤1，创建插件宿主程序；步骤2，定义插件宿主程序与插件之间的接口规范；步骤3，针对不同的外场感知设备的数据采集协议生成相对应的数据采集插件；步骤4，创建事件流处理引擎；步骤5，为事件流处理引擎定义时间窗口或长度窗口；步骤6，针对不同的外场感知设备的数据采集协议实现相对应的数据处理规则；步骤7，定义并注册事件；步骤8，将注册的事件分别与步骤6中实现的各种数据处理规则相关联；步骤9，设置事件处理条件；步骤10，创建源数据队列以及目标队列；步骤11，创建消费线程；步骤12，将目标数据导出到目的地；步骤13，创建守护进程。