一种基于订阅的数据预警方法

摘要

本发明提供一种基于订阅的数据预警方法，是基于订阅的预警方法实现了数据检测与数据处理的分离，系统管理员或者维护人员定义数据检测的条件及执行频率。普通用户可以订阅此定义，并设置自己通知方式、通知内容和订阅频率。数据检测与处理分离之后，接收用户变成参与者，用户可以在订阅中定义自己喜好的通知方式、通知内容和订阅频率。数据检测频率和订阅频率可以不一致，满足了不同用户对数据及时性和频度不同需求的支持，同一个预警可以在不同的时间以不同的通知方式告知。比如周末有人要求不接受通知，出差时间不接受通知等等。

主权项

1.一种基于订阅的数据预警方法，其特征在于，步骤如下：1)基于订阅的预警方法实现数据检测与数据处理的分离，系统管理员或者维护人员定义数据检测的条件及执行频率，普通用户订阅此定义，并设置自己通知方式、通知内容和订阅频率；2)数据检测与处理分离之后，接收用户变成参与者，用户在订阅中定义自己喜好的通知方式、通知内容和订阅频率，允许数据检测频率和订阅频率不一致，以满足不同用户对数据及时性和频度不同需求的支持，同一个预警在不同的时间以不同的通知方式告知，包括周末有人要求不接受通知，出差时间不接受通知；3)基于订阅的数据预警方法有定义时和运行时两阶段构成，定义时有数据检测定义、订阅定义两个部分实现，运行时有生成取数计划、执行取数、存储取数数据、分发订阅四部分组成，其中：(1)定义时，主要完成对预警的定义，定义时主要分为数据检测定义和订阅定义，它们的关系是一对多的关系；a)数据检测定义的主要步骤有：步骤一：数据检测频率定义：定义预警检测的频率和开始、结束时间；步骤二：数据检测定义，数据检测定义有预警条件定义和数据结果结构定义两部分组成；步骤三：订阅参数定义。定义数据检测定义中被订阅者赋值的参数；步骤二中提到的预警条件定义是定义预警的数据源和在数据源上的过滤条件，过滤条件的值设置为订阅参数，由订阅用户在订阅时赋值；步骤二中提到的数据结果结构定义是定义预警结果集的数据结构，订阅用户使用此数据结构访问订阅到的数据，并组织通知内容；预警执行时会根据订阅参数的赋值情况生成取数计划并执行预警；b)订阅定义的主要步骤有：步骤一：订阅参数赋值，定义订阅者关心的预警过滤条件的实际值；步骤二：订阅频率定义，定义订阅的接收频率；步骤三：数据再加工条件定义，在取数计划提取的数据基础上再进行条件过滤，此次过滤之后的数据是真正预警的数据；步骤四：订阅定义，定义通知方式定义、通知内容定义和接收人定义；步骤二中的订阅频率需要从数据检测频率中选取，不能是数据检测频率之外的时间；步骤二中订阅频率是指定有效期，包括只能在工作日和工作时间内订阅预警；步骤四中的通知方式定义主要选择系统支持的通知方式，包括邮件方式、短信方式；步骤四中的通知内容是定义通知的格式和参数，在发送通知时，系统会把参数替换为预警数据，形成通知并发送；(2)运行时运行时主要有生成取数计划、取数、数据存储、分发订阅四部分组成，分发订阅又有订阅用户数据再加工、生成通知、发送通知三部分组成，运行时按照流程的具体执行步骤如下：步骤一：生成取数计划，由于订阅频率与数据检测频率的不同，与数据检测定义对应的所有订阅并不都需要执行；在订阅参数可能存在相同的情况下，为了过滤有效订阅者并提高预警执行的效率，在预警执行时需要首先生成取数计划，取数计划的内容包括：取数条件、订阅参数值和订阅列表；步骤二：取数，生成取数计划之后，系统会对取数计划中的任务逐一执行；步骤三：数据存储，取数完成之后，系统会把结果集，以及结果集与订阅列表进行存储；步骤四：分发订阅，按照取数计划中记录的订阅列表发布订阅信息，分发订阅有数据再加工、生成通知、发送通知组成；步骤一中的过滤有效订阅者的规则为：订阅频率中存在与当前预警执行的时间点相同的时间，并且当前预警时间点满足订阅者对订阅有效期的限制，则认为此订阅是本次预警的有效订阅；步骤一中过滤出有效订阅者之后，系统根据每个订阅者的订阅参数赋值情况生成取数计划，生成取数计划的规则为：一个订阅者的订阅参数与其他订阅者的订阅参数的赋值情况完全相同，则认为这些订阅合并为一次取数，并生成一个计划，此计划与这些订阅关联；步骤四中的数据再加工是指在数据存储完毕之后，系统会针对每个订阅触发一个流程，此流程根据数据与订阅的对照关系逐个触发预警的订阅，在订阅中，首先根据订阅者设置的数据再加工条件对数据进行再次过滤，过滤之后的数据是预警的数据；步骤四中的生成通知是把通知内容中的参数替换为预警的数据，并生成邮件或者短信可接收的数据格式；步骤四中的发送通知是根据通知方式调用不同消息发送程序执行消息的发送；基于订阅的数据预警方法虽然实现了取数与通知的分离，但也支持现有的预警方式。