1.一种时序数据库内置流处理有状态插件管理系统,其特征在于,所述系统包括:消息模块、数据模块、管理模块和监控模块;
所述消息模块负责维护插件实例的生命周期状态信息,并协调其他模块之间的通信;
所述插件实例包括抽取插件实例、处理插件实例和递送插件实例;所述生命周期状态信息包括等待状态、休眠状态、准备状态和运行状态;
所述数据模块负责接收、存储并整理插件实例之间传输的所需数据;所述所需数据包括特定时间段的数据和特定设备的数据;
所述管理模块负责加载插件实例并令加载后的插件实例处于等待状态,保存插件实例在休眠状态下所需数据的过滤条件,提供插件实例在准备状态下所需数据的过滤条件,移除插件实例在运行状态下所需数据的过滤条件;
所述监控模块负责监控服务器资源使用情况和处理休眠状态的插件实例的休眠时长,并根据监控结果动态调整系统资源;以及将插件实例从休眠状态转换为准备状态。
2.根据权利要求1所述的一种时序数据库内置流处理有状态插件管理系统,其特征在于,所述消息模块包括:信息存储单元、消息分发单元;
所述信息存储单元负责存储插件实例的生命周期状态信息,为其他模块提供插件实例生命周期状态信息的查询服务;
所述消息分发单元负责接收其他模块的请求,并将请求转发到相应的插件实例。
3.根据权利要求1所述的一种时序数据库内置流处理有状态插件管理系统,其特征在于,所述数据模块包括:数据接收单元、数据整理单元以及数据回收单元;
所述数据接收单元负责接收插件实例共享的所需数据;
所述数据整理单元负责监控数据接收单元,接收所有处于休眠状态的插件实例的所需数据,按照插件实例类型分类存储所需数据,并将分类存储的插件实例及其所需数据的相关信息发送到消息模块或数据回收单元;
所述数据回收单元负责处理未发送到消息模块的插件实例及其所需数据的相关信息,对于特定时间段的数据,将其发送至外部第三方系统;对于特定设备的数据,直接丢弃。
4.根据权利要求1所述的一种时序数据库内置流处理有状态插件管理系统,其特征在于,所述管理模块包括:实例加载单元、过滤条件单元;
所述实例加载单元负责根据用户配置信息加载插件实例,加载完成后,将插件实例的生命周期状态信息注册到消息模块;
所述过滤条件单元负责保存处于休眠状态的插件实例所需数据的过滤条件,提供插件实例在准备状态下所需数据的过滤条件,移除插件实例在运行状态下所需数据的过滤条件;所述过滤条件包括特定时间段的过滤条件和特定设备的过滤条件。
5.根据权利要求1所述的一种时序数据库内置流处理有状态插件管理系统,其特征在于,所述监控模块包括:休眠监控单元、系统监控单元;
所述休眠监控单元负责监控插件实例在休眠状态下的休眠时长,若发现某插件实例在休眠状态下的休眠时间超过最大限制,将强制唤醒该插件实例;唤醒后,通知消息模块更新插件实例的生命周期状态信息,并从数据模块获取该插件实例在休眠状态下被过滤的所需数据,同时从管理模块中移除该插件实例在运行状态下的过滤条件;
所述系统监控单元负责监控系统的平均使用率,若发现平均使用率超过预设范围,将动态调整运行流处理任务的插件实例的数量。