业务规则管理方法、事件处理方法及事件处理平台与流程

本公开涉及安防数据处理领域，特别涉及一种业务管理方法、事件处理方法及其事件处理平台。

背景技术：

1、现有技术中，iot（internet of things，物联网）设备例如摄像头、门铃及各种传感器可以实时监测周围环境的变化，并在监测到该变化满足预设条件时，触发告警动作。

2、告警动作可能包括多种类型，例如可以包括推送类型，例如可以包括联动类型。

3、在推送类型中，既可能包括采用公有协议的第三方生态的推送，例如可以包括向指定设备推送仅包括纯文本信息的邮件、短信或通知；又可能包括采用私有协议的自有生态的推送，例如可以包括向指定设备推送既包括纯文本信息、又包括附图信息的邮件、短信或通知，又例如可以包括向指定设备推送既包括纯文本信息、又包括音频信息的邮件、短信或通知。

4、在联动类型中，可以包括设备间直接的动作触发，例如一个设备的状态变化直接控制另一个设备的执行动作；也可以包括场景化联动，即根据预设的“场景模式”同时触发多个设备执行一系列协同动作。此外，在联动类型关联的设备中，既可以包括第三方生态设备，又可以包括自有生态设备。

5、不同第三方生态设备所采用的公有协议可能不同，不同自有生态设备所采用的私有协议也可能不同。

6、随着事件信息处理所涉及的设备及告警动作的不断丰富，现有技术只能支持单一告警动作或单一生态设备处理的单一事件驱动服务，已经难以满足人们日益增长的个性化需求。

7、因此，亟须提供一种能够高效处理多种事件信息的事件处理方法或平台。

技术实现思路

1、本公开为解决上述技术问题，提供一种业务管理方法、事件处理方法及其事件处理平台，能够高效处理多种事件信息，具有良好的兼容性和可扩展性。

2、本公开提供一种事件处理方法，所述方法包括：获取事件源上报的事件信息；基于所述事件信息和预先存储的预设格式的业务规则，从事件驱动服务中，确定目标事件驱动服务；发送所述事件信息至所述目标事件驱动服务，以使所述目标事件驱动服务响应所述事件信息。

3、可选择地，所述业务规则包括业务类型，不同所述事件驱动服务对应支持不同所述业务类型的所述业务规则，所述事件信息至少对应一个所述业务规则，所述基于所述事件信息和预先存储的预设格式的业务规则，从事件驱动服务中，确定目标事件驱动服务，包括：基于所述事件信息和所述业务规则，确定所述事件信息对应的所述业务类型；基于所述业务类型，从所述事件驱动服务中，确定所述目标事件驱动服务。

4、可选择地，所述事件信息包括第一特征信息，所述业务规则包括第二特征信息，所述基于所述事件信息和所述业务规则，确定所述事件信息对应的所述业务类型，包括：获取所述事件信息中的所述第一特征信息；在所述业务规则中，查询到所述第二特征信息与所述第一特征信息匹配时，确定所述业务规则为目标业务规则；确定所述目标业务规则中的所述业务类型为所述事件信息对应的所述业务类型。

5、可选择地，所述业务规则包括所述事件源的设备信息和订阅事件信息，所述第一特征信息包括第一键值，所述第二特征信息包括基于所述设备信息和所述订阅事件信息生成的第二键值，所述在所述业务规则中，查询到所述第二特征信息与所述第一特征信息匹配时，确定所述业务规则为目标业务规则，包括：从所述事件信息中解析获得所述事件源的设备信息和订阅事件信息；基于所述设备信息和所述订阅事件信息生成所述第一键值；在所述业务规则中，查询到所述第二键值与所述第一键值匹配时，确定所述业务规则为所述目标业务规则。

6、本公开还提供一种业务规则管理方法，所述方法包括：获取第一业务规则和/或从其它服务获取第二业务规则；解析所述第一业务规则和/或所述第二业务规则，并转换成预设格式的业务规则；存储所述预设格式的业务规则至数据存储服务，以供基于事件源上报的事件信息和所述业务规则，从事件驱动服务中，确定用于响应所述事件信息的目标事件驱动服务。

7、可选择地，所述方法还包括：解析所述第一业务规则，获得事件源及其订阅事件；基于所述事件源和所述订阅事件生成通道配置指令；发送所述通道配置指令至所述事件源，以激活所述事件源对应于所述订阅事件的上报通道，所述上报通道激活后，所述事件源仅上报满足所述订阅事件的所述事件信息。

8、可选择地，所述解析所述第一业务规则和/或所述第二业务规则，并转换成预设格式的业务规则，包括：解析所述第一业务规则和/或所述第二业务规则；对解析后的所述第一业务规则和/或所述第二业务规则进行去重处理；转换去重后的所述第一业务规则和/或所述第二业务规则成所述预设格式的业务规则；其中，所述去重处理包括删除所述第一业务规则和/或所述第二业务规则中，具有相同的事件源、订阅事件、执行器及执行动作的业务规则。

9、本公开还提供一种一种事件处理服务平台，所述平台包括：数据接入层，用于接收事件源上报的事件信息；数据存储服务，用于存储预设格式的业务规则；事件调度服务，与所述数据接入层和所述数据存储服务通信，用于获取数据接入层接收的所述事件信息，基于所述事件信息和所述数据存储服务中的预设格式的业务规则，从事件驱动服务中，确定目标事件驱动服务，发送所述事件信息至所述目标事件驱动服务，以使所述目标事件驱动服务响应所述事件信息。

10、可选择地，所述平台还包括所述事件驱动服务，所述事件驱动服务与所述事件调度服务通信，用于接收所述事件调度服务发送的所述事件信息，并根据所述事件信息对应的所述业务规则，对所述事件信息进行响应。

11、可选择地，所述事件驱动服务包括第一事件驱动服务和第二事件驱动服务，所述第二事件驱动服务与所述第一事件驱动服务通信，其中：所述第二事件驱动服务用于响应于用户的第二配置操作生成第二业务规则；所述第一事件驱动服务用于响应于用户的第一配置操作生成第一业务规则，获取所述第二事件驱动服务生成的所述第二业务规则，解析所述第一业务规则和/或所述第二业务规则，并转换成预设格式的业务规则，进而存储至所述数据存储服务。

12、可选择地，所述数据接入层包括相互通信的数据接入节点和数据缓存组件，所述数据接入节点用于接收所述事件源上报的所述事件信息，所述数据缓存组件用于接收并缓存所述数据接入节点发送的所述事件信息；所述事件调度服务与所述数据缓存组件通信，以从所述数据缓存组件中获取所述事件信息。

13、可选择地，所述事件调度服务基于所述事件信息生成的时间戳的先后顺序依次读取并处理所述事件信息。

14、可选择地，所述业务规则包括订阅事件及所述订阅事件的优先级，所述第一事件驱动服务建立所述订阅事件及优先级之间的映射关系并存储至所述数据存储服务，所述数据接入节点通过所述第一事件驱动服务与所述数据存储服务通信并获取所述映射关系，所述数据接入节点接收所述事件信息后，基于所述映射关系确定所述事件信息对应的所述订阅事件的优先级，并附加所述优先级至所述事件信息后发送至所述数据缓存组件缓存，所述数据缓存组件基于所述事件信息的时间戳和所述优先级对所述事件信息进行排序，所述事件调度服务按照所述事件信息的时间戳的先后顺序进行调度，且当存在高优先级的所述事件信息时，优先调度所述高优先级的所述事件信息。

15、可选择地，所述事件处理平台部署于网络节点和/或边缘节点。

16、可选择地，所述网络节点包括云服务器。

17、可选择地，所述边缘节点包括网络视频录像机和/或集线器。

18、可选择地，所述事件源包括具有联网功能的硬件设备和/或软件系统，所述硬件设备包括事件处理服务平台，所述软件系统包括业务系统、中间件、数据库和/或软件交互界面。

19、可选择地，所述事件处理服务平台包括传感器设备、智能仪表、摄像头、门铃、定位标签、可穿戴设备、智能家电、智能办公设备和/或车载终端。

20、本公开还提供一种计算机可读存储介质，所述计算机可读存储介质包括指令，当所述指令在处理器上加载时，使得所述处理器执行本公开提供的任一项所述的通信方法的步骤。

21、本公开提供的业务管理方法、事件处理方法及其事件处理平台，具有如下有益效果：

22、通过基于事件信息和预设格式的业务规则确定目标事件驱动服务，能够实现事件处理的规则化路由，使得对应于不同事件驱动服务的事件信息能够被动态分发至对应的事件驱动服务，进而可以有效避免由单一事件驱动服务处理所有事件信息所导致的性能瓶颈，并降低因该单一事件驱动服务故障而影响整体事件处理链路的风险；同时，当业务场景变化时，仅需调整业务规则即可改变事件路由策略，能够提升系统的可扩展性，进而可以满足用户对业务规则的个性化需求或定制化需求。