空气质量信息的自动生成及发送方法、装置、设备及介质

摘要

本申请公开了一种空气质量信息的自动生成及发送方法、装置、设备及介质。该方法包括：获取爬取周期阈值；分别控制多个代理节点中的爬虫程序以大于爬取周期阈值的爬取周期登录待爬取网站，并对各待爬取网页进行渲染，得到已渲染网页；分别控制多个代理节点中的爬虫程序协同爬取各已渲染网页的数据；将爬取得到的网页数据与规则库内的预设规则进行关联分析；根据关联分析的结果以及所述预设规则中的告警条件，生成告警信息并发送告警信息。通过本申请的方法，不再需要用户频繁主动登录网站来获取空气质量信息，用户只需要被动接收空气质量信息即可，大大方便了用户得到空气质量信息。

权利要求

1.一种空气质量信息的自动生成及发送方法，其特征在于，包括：获取爬取周期阈值，所述爬取周期阈值是触发待爬取网站发起互联网协议封锁操作的最大周期值；

分别控制多个代理节点中的爬虫程序以大于爬取周期阈值的爬取周期登录待爬取网站，并对所述待爬取网站的各待爬取网页进行渲染，得到已渲染网页；其中，所述大于爬取周期阈值的爬取周期的值为大于爬取周期阈值的最小值；各所述代理节点的互联网协议地址互不相同；各所述代理节点的爬虫程序分别渲染不同的所述待爬取网页；

分别控制多个代理节点中的爬虫程序协同爬取各已渲染网页的数据；

将爬取得到的网页数据与规则库内的预设规则进行关联分析；

根据关联分析的结果以及所述预设规则中的告警条件，生成告警信息并发送所述告警信息；

其中，所述分别控制多个代理节点中的爬虫程序协同爬取各已渲染网页的数据包括：将爬取所述各已渲染网页的数据的整体任务划分为多个部分任务；

控制所述多个代理节点各自分担相应的所述部分任务，进行爬取；

对各所述代理节点所爬取的数据进行汇总，得到完成所述整体任务后的数据；

所述预设规则包括存在关联关系的属性种类和阈值；所述预设规则包括若干种所述属性种类，每一种所述属性种类对应关联一个所述阈值；所述将爬取得到的网页数据与规则库内的预设规则进行关联分析，包括：从所述规则库内的预设规则中查找与所述爬取得到的网页数据相匹配的属性种类；

将所述爬取得到的网页数据的值，与所述相匹配的属性种类所关联的阈值进行比对，获得污染物浓度比对结果；

所述从所述规则库内的预设规则中查找与所述爬取得到的网页数据相匹配的属性种类，包括：

规则引擎读取并解析规则库，并对预设的规则进行编译加载；将爬取得到的网页数据生成特征向量模型规则；

将爬取得到的网页数据生成待分析的实时事件流；

将特征向量数据流输入到特征向量模型规则中进行模型规则匹配；

规则引擎订阅待分析的实时事件流，并将上述待分析的实时事件流与上述预设的规则进行关联规则匹配，得到与所述实时事件流相匹配的属性种类；其中，所述实时事件流的定义字段包括事件类型、事件来源、设备互联网协议地址、事件时间、源互联网协议地址、目的互联网协议地址、日志内容以及根据不同事件类型自定义的字段。

2.根据权利要求1所述的方法，其特征在于，所述对所述待爬取网站的各待爬取网页进行渲染，得到已渲染网页，包括：获取所述待爬取网页的源代码；

检测所述源代码中的元素节点是否符合预设特征要求；所述元素节点与所述待爬取网页中的素材资源对应，所述预设特征要求指示所述元素节点对应的网页素材资源在所述待爬取网页中的显示效果；

当所述元素节点符合所述预设特征要求时，停止对所述元素节点对应网页素材资源的渲染操作。

3.根据权利要求1所述的方法，其特征在于，所述发送所述告警信息，包括：调用微信公众平台提供的接口向关注微信公众号的用户终端推送所述告警信息；或者直接将所述告警信息发送到用户终端。

4.一种空气质量信息的自动生成及发送装置，其特征在于，包括：获取模块，用于获取爬取周期阈值，所述爬取周期阈值是触发待爬取网站发起互联网协议封锁操作的最大周期值；

渲染模块，用于分别控制多个代理节点中的爬虫程序以大于爬取周期阈值的爬取周期登录待爬取网站，并对所述待爬取网站的各待爬取网页进行渲染，得到已渲染网页；所述大于爬取周期阈值的爬取周期的值为大于爬取周期阈值的最小值；各所述代理节点的互联网协议地址互不相同；各所述代理节点的爬虫程序分别渲染不同的所述待爬取网页；

爬取模块，用于分别控制多个代理节点中的爬虫程序协同爬取各已渲染网页的数据；

分析模块，用于将爬取得到的网页数据与规则库内的预设规则进行关联分析；

告警模块，用于根据关联分析的结果以及所述预设规则中的告警条件，生成告警信息并发送所述告警信息；

其中，所述爬取模块包括：

划分单元，用于将爬取所述各已渲染网页的数据的整体任务划分为多个部分任务；

爬取单元，用于控制所述多个代理节点各自分担相应的所述部分任务，进行爬取；

汇总单元，用于对各所述代理节点所爬取的数据进行汇总，得到完成所述整体任务后的数据；

所述预设规则包括存在关联关系的属性种类和阈值；所述预设规则包括若干种所述属性种类，每一种所述属性种类对应关联一个所述阈值；所述分析模块，包括：查找单元，用于从所述规则库内的预设规则中查找与所述爬取得到的网页数据相匹配的属性种类；

比对单元，用于将所述爬取得到的网页数据的值，与所述相匹配的属性种类所关联的阈值进行比对，获得污染物浓度比对结果；

所述查找单元，具体用于：

规则引擎读取并解析规则库，并对预设的规则进行编译加载；将爬取得到的网页数据生成特征向量模型规则；

将爬取得到的网页数据生成待分析的实时事件流；

将特征向量数据流输入到特征向量模型规则中进行模型规则匹配；

规则引擎订阅待分析的实时事件流，并将上述待分析的实时事件流与上述预设的规则进行关联规则匹配，得到与所述实时事件流相匹配的属性种类；其中，所述实时事件流的定义字段包括事件类型、事件来源、设备互联网协议地址、事件时间、源互联网协议地址、目的互联网协议地址、日志内容以及根据不同事件类型自定义的字段。

5.根据权利要求4所述的装置，其特征在于，所述渲染模块包括渲染单元，所述渲染单元用于对所述待爬取网站的各待爬取网页进行渲染，得到已渲染网页；所述渲染单元包括：获取子单元，用于获取所述待爬取网页的源代码；

检测子单元，用于检测所述源代码中的元素节点是否符合预设特征要求；所述元素节点与所述待爬取网页中的素材资源对应，所述预设特征要求指示所述元素节点对应的网页素材资源在所述待爬取网页中的显示效果；

停止子单元，用于当所述元素节点符合所述预设特征要求时，停止对所述元素节点对应网页素材资源的渲染操作。

6.根据权利要求4所述的装置，其特征在于，所述告警模块包括发送单元，所述发送单元用于发送所述告警信息；所述发送单元具体用于：调用微信公众平台提供的接口向关注微信公众号的用户终端推送所述告警信息；或者直接将所述告警信息发送到用户终端。

7.一种电子设备，其特征在于，包括存储器、处理器及存储在所述存储器上并可在所述处理器上运行的计算机程序，所述处理器执行所述程序，以实现如权利要求1‑3中任一所述的空气质量信息的自动生成及发送方法。

8.一种计算机可读存储介质，其上存储有计算机程序，其特征在于，该程序被处理器执行，以实现如权利要求1‑3中任一所述的空气质量信息的自动生成及发送方法。

说明书

空气质量信息的自动生成及发送方法、装置、设备及介质

技术领域

[0001] 本申请涉及环境监控技术领域，具体涉及一种空气质量信息的自动生成及发送方法、装置、设备及介质。

背景技术

[0002] 随着经济的发展和社会的进步，人们对空气质量问题越来越重视，越来越多地关注各种空气质量信息。目前人们大多是通过浏览各种空气质量数据发布网站的方式来获取
空气质量数据，这就需要频繁登录各种网站，然后根据浏览网站所获得的空气质量数据作
出关于空气质量状况的判断。当前的这种方式显然不方便，亟待研发一种能够自动生成空
气质量信息并发送的技术方案。

发明内容

[0003] 本申请的目的是提供一种空气质量信息的自动生成及发送方法、装置、设备及介质。为了对披露的实施例的一些方面有一个基本的理解，下面给出了简单的概括。该概括部
分不是泛泛评述，也不是要确定关键/重要组成元素或描绘这些实施例的保护范围。其唯一
目的是用简单的形式呈现一些概念，以此作为后面的详细说明的序言。

[0004] 根据本申请实施例的一个方面，提供一种空气质量信息的自动生成及发送方法，包括：

[0005] 获取爬取周期阈值，所述爬取周期阈值是触发待爬取网站发起互联网协议封锁操作的最大周期值；

[0006] 分别控制多个代理节点中的爬虫程序以大于爬取周期阈值的爬取周期登录待爬取网站，并对所述待爬取网站的各待爬取网页进行渲染，得到已渲染网页；

[0007] 分别控制多个代理节点中的爬虫程序协同爬取各已渲染网页的数据；

[0008] 将爬取得到的网页数据与规则库内的预设规则进行关联分析；

[0009] 根据关联分析的结果以及所述预设规则中的告警条件，生成告警信息并发送所述告警信息。

[0010] 进一步地，所述对所述待爬取网站的各待爬取网页进行渲染，得到已渲染网页，包括：

[0011] 获取所述待爬取网页的源代码；

[0012] 检测所述源代码中的元素节点是否符合预设特征要求；所述元素节点与所述待爬取网页中的素材资源对应，所述预设特征要求指示所述元素节点对应的网页素材资源在所
述待爬取网页中的显示效果；

[0013] 当所述元素节点符合所述预设特征要求时，停止对所述元素节点对应网页素材资源的渲染操作。

[0014] 进一步地，所述将爬取得到的网页数据与规则库内的预设规则进行关联分析，包括：

[0015] 从所述规则库内的预设规则中查找与所述爬取得到的网页数据相匹配的属性种类；

[0016] 将所述爬取得到的网页数据的值，与所述相匹配的属性种类所关联的阈值进行比对，获得污染物浓度比对结果。

[0017] 进一步地，所述发送所述告警信息，包括：

[0018] 调用微信公众平台提供的接口向关注微信公众号的用户终端推送所述告警信息；或者直接将所述告警信息发送到用户终端。

[0019] 根据本申请实施例的另一个方面，提供一种空气质量信息的自动生成及发送装置，包括：

[0020] 获取模块，用于获取爬取周期阈值，所述爬取周期阈值是触发待爬取网站发起互联网协议封锁操作的最大周期值；

[0021] 渲染模块，用于分别控制多个代理节点中的爬虫程序以大于爬取周期阈值的爬取周期登录待爬取网站，并对所述待爬取网站的各待爬取网页进行渲染，得到已渲染网页；

[0022] 爬取模块，用于分别控制多个代理节点中的爬虫程序协同爬取各已渲染网页的数据；

[0023] 分析模块，用于将爬取得到的网页数据与规则库内的预设规则进行关联分析；

[0024] 告警模块，用于根据关联分析的结果以及所述预设规则中的告警条件，生成告警信息并发送所述告警信息。

[0025] 进一步地，所述渲染模块包括渲染单元，所述渲染单元用于对所述待爬取网站的各待爬取网页进行渲染，得到已渲染网页；所述渲染单元包括：

[0026] 获取子单元，用于获取所述待爬取网页的源代码；

[0027] 检测子单元，用于检测所述源代码中的元素节点是否符合预设特征要求；所述元素节点与所述待爬取网页中的素材资源对应，所述预设特征要求指示所述元素节点对应的
网页素材资源在所述待爬取网页中的显示效果；

[0028] 停止子单元，用于当所述元素节点符合所述预设特征要求时，停止对所述元素节点对应网页素材资源的渲染操作。

[0029] 进一步地，所述分析模块，包括：

[0030] 查找单元，用于从所述规则库内的预设规则中查找与所述爬取得到的网页数据相匹配的属性种类；

[0031] 比对单元，用于将所述爬取得到的网页数据的值，与所述相匹配的属性种类所关联的阈值进行比对，获得污染物浓度比对结果。

[0032] 进一步地，所述告警模块包括发送单元，所述发送单元用于发送所述告警信息；所述发送单元具体用于：

[0033] 调用微信公众平台提供的接口向关注微信公众号的用户终端推送所述告警信息；或者直接将所述告警信息发送到用户终端。

[0034] 根据本申请实施例的另一个方面，提供一种电子设备，包括存储器、处理器及存储在所述存储器上并可在所述处理器上运行的计算机程序，所述处理器执行所述程序，以实
现上述的空气质量信息的自动生成及发送方法。

[0035] 根据本申请实施例的另一个方面，提供一种计算机可读存储介质，其上存储有计算机程序，该程序被处理器执行，以实现上述的空气质量信息的自动生成及发送方法。

[0036] 本申请实施例的其中一个方面提供的技术方案可以包括以下有益效果：

[0037] 本申请实施例提供的空气质量信息的自动生成及发送方法，通过分别控制多个代理节点中的爬虫程序以大于爬取周期阈值的爬取周期登录待爬取网站，并对各待爬取网页
进行渲染，分别控制多个代理节点中的爬虫程序协同爬取各已渲染网页的数据，将爬取得
到的网页数据与规则库内的预设规则进行关联分析，根据关联分析的结果以及预设规则中
的告警条件，生成告警信息并发送，不再需要用户频繁主动登录网站来获取空气质量信息，
用户只需要被动接收空气质量信息即可，大大方便了用户得到空气质量信息。

[0038] 本申请的其他特征和优点将在随后的说明书中阐述，并且，部分地从说明书中变得显而易见，或者，部分特征和优点可以从说明书中推知或毫无疑义地确定，或者通过实施
本申请实施例了解。本申请的目的和其他优点可通过在所写的说明书、权利要求书、以及附
图中所特别指出的结构来实现和获得。

附图说明

[0039] 为了更清楚地说明本申请实施例或现有技术中的技术方案，下面将对实施例或现有技术描述中所需要使用的附图作简单地介绍，显而易见地，下面描述中的附图仅仅是本
申请中记载的一些实施例，对于本领域普通技术人员来讲，在不付出创造性劳动的前提下，
还可以根据这些附图获得其他的附图。

[0040] 图1示出了本申请的一个实施例的空气质量信息的自动生成及发送方法的流程图；

[0041] 图2示出了图1所对应实施例中的步骤S10的流程图；

[0042] 图3示出了图1所对应实施例中的步骤S30的流程图；

[0043] 图4示出了本申请的另一实施例的空气质量信息的自动生成及发送装置的结构框图；

[0044] 图5示出了本申请的另一实施例的电子设备的结构框图。

具体实施方式

[0045] 为了使本申请的目的、技术方案及优点更加清楚明白，下面结合附图和具体实施例对本申请做进一步说明。应当理解，此处所描述的具体实施例仅用以解释本申请，并不用
于限定本申请。基于本申请中的实施例，本领域普通技术人员在没有做出创造性劳动前提
下所获得的所有其他实施例，都属于本申请保护的范围。

[0046] 本技术领域技术人员可以理解，除非另外定义，这里使用的所有术语(包括技术术语和科学术语)，具有与本申请所属领域中的普通技术人员的一般理解相同的意义。还应该
理解的是，诸如通用字典中定义的那些术语，应该被理解为具有与现有技术的上下文中的
意义一致的意义，并且除非像这里一样被特定定义，否则不会用理想化或过于正式的含义
来解释。

[0047] 如图1所示，本申请的一个实施例提供了一种空气质量信息的自动生成及发送方法，包括以下步骤：

[0048] 步骤S00、获取爬取周期阈值；该爬取周期阈值是触发待爬取网站发起互联网协议封锁操作的最大周期值。

[0049] 例如，待爬取网站为某空气质量数据发布网站“空气质量监测网”，爬取周期阈值为15分钟，即0.25小时，则当访问节点通过爬虫程序以大于0.25小时的爬取周期爬取“空气
质量监测网”的网页数据时，“空气质量监测网”不会通过对该访问节点的互联网协议地址
进行封锁操作以达到拒绝该访问节点访问的目的，而当访问节点通过爬虫程序以等于或小
于0.25小时的爬取周期爬取“空气质量监测网”的网页数据时，“空气质量监测网”则会对该
访问节点的互联网协议地址进行封锁，从而达到拒绝该访问节点在此访问的目的。

[0050] 步骤S10、分别控制多个代理节点中的爬虫程序以大于爬取周期阈值的爬取周期登录待爬取网站，并对待爬取网站的各待爬取网页进行渲染，得到已渲染网页。

[0051] 各代理节点中的爬虫程序按照爬取周期登录待爬取网站后，分别对各自承担的待爬取网页进行渲染，得到已渲染网页。例如，总共采用n个代理节点登录待爬取网站，待爬取
网站总共有3n个待爬取网页，则每一代理节点承担3个待爬取网页，代理节点首先将分配到
的3个待爬取网页进行渲染，得到3个已渲染网页。爬虫程序按照登录网站、渲染网页、爬取
已渲染网页的数据的流程进行网页数据爬取。

[0052] 如图2所示，在某些实施方式中，步骤S10中对待爬取网站的各待爬取网页进行渲染，得到已渲染网页，包括：

[0053] S101、获取待爬取网页的源代码。

[0054] 以某空气质量数据发布网站“空气质量监测网”为例，从“空气质量监测网”的网站服务器处获取各待爬取网页的源代码，例如，该源代码可以是网页的HTML代码。进行网页页
面渲染，即对各个网页素材资源对应的元素节点进行渲染。

[0055] S102、检测源代码中的元素节点是否符合预设特征要求；元素节点与待爬取网页中的素材资源对应，预设特征要求指示元素节点对应的网页素材资源在待爬取网页中的显
示效果。

[0056] 预设特征要求是通过对待爬取网页中广告的显示特征进行分析得到的。该预设特征要求可以包括元素节点的节点CSS特征和节点内容特征中的至少一种，其中，CSS特征用
于指示元素节点对应的网页素材资源的显示样式，节点内容特征用于指示元素节点对应的
网页素材资源中包含的显示内容。

[0057] S103、当元素节点符合预设特征要求时，停止对该元素节点对应网页素材资源的渲染操作。

[0058] 对于符合预设特征要求的元素节点，将其确定为广告节点，并停止对该广告节点对应的素材资源进行渲染，从而起到广告拦截的作用。

[0059] 例如，当元素节点符合节点CSS特征时，确定该元素节点为广告节点；当元素节点符合节点内容特征，确定该元素节点为广告节点；当元素节点符合节点CSS特征以及节点内
容特征时，确定该元素节点为广告节点。

[0060] 由于网页中广告的显示特征较为明显且变化较小，预设特征要求不需要进行频繁的更新，显著降低了广告过滤的难度和成本；并且，在进行网页渲染时无需对广告资源对应
的元素节点进行渲染，能够提升网页的渲染速度和性能。

[0061] 步骤S20、分别控制多个代理节点中的爬虫程序协同爬取各已渲染网页的数据。

[0062] 其中，各代理节点的互联网协议地址互不相同。

[0063] 仍以某空气质量数据发布网站“空气质量监测网”为例，触发“空气质量监测网”发起互联网协议封锁操作的周期登录阈值往往是根据对网页数据的登录周期而设定的，因此
相较于使用爬虫程序进行网页数据的登录爬取而言，周期相对较大，为了在对“空气质量监
测网”进行网页数据的爬取过程避免触发“空气质量监测网”的互联网协议封锁操作的同
时，确保对“空气质量监测网”中的网页数据爬取的整体效率，本步骤采用控制多个代理节
点中的爬虫程序以小于爬虫频率阈值的目标爬虫频率以协同工作的方式爬取“空气质量监
测网”中的网页数据，此处所指的协同工作，是指将对“空气质量监测网”完整的爬取任务划
分为多个部分任务，并由多个代理节点各自分担相应的部分任务，最终通过对各代理节点
的部分任务结果进行汇总得到完整的爬取任务相应的网页数据。

[0064] 本步骤中的大于爬取周期阈值的爬取周期可以是大于爬取周期阈值(例如0.25小时)的任意周期，但是考虑到应最大程度地降低对于待爬取网站的爬取周期，因此优选大于
爬取周期阈值的爬取周期的值可以为大于爬取周期阈值的最小值。另外，各个代理节点的
互联网协议地址互不相同的目的是为了确保各个代理节点的对于待爬取网站而言都是不
同身份的访问节点，避免触发待爬取网站对互联网协议地址的封锁操作。

[0065] 本实施例中的网页数据爬取步骤，首先获取爬虫触发待爬取网站的互联网协议封锁操作时的数据爬取周期，将该数据爬取周期作为爬取周期阈值，进而控制多个代理节点
中的爬虫程序分别以大于爬虫周期阈值的爬取周期登录待爬取网站，渲染各待爬取网页得
到已渲染网页后，协同爬取已渲染网页的数据，其中，各个代理节点所使用的互联网协议地
址互不相同。通过获取爬取周期阈值，并将爬取周期阈值作为各个代理节点对待爬取网站
的爬取周期下限，能够相对避免出现各代理节点的互联网协议地址被待爬取网站封锁的情
况发生，进而保证了对网页数据进行爬取过程的可靠性，避免了互联网协议资源的浪费；此
外，本方法通过多个代理节点协同工作的方式爬取待爬取网站中各网页数据，提高了网页
数据爬取过程的整体效率。

[0066] 步骤S30、将爬取得到的网页数据与规则库内的预设规则进行关联分析。

[0067] 在某些实施方式中，规则库内的预设规则包括存在关联关系的属性种类和阈值；预设规则包括n种属性种类，每一种属性种类对应关联一个阈值，例如，其中的一个属性种
3 3
类为PM2.5，对应关联的阈值为30μg/m，另一属性种类为PM10，对应关联的阈值为70μg/m。

[0068] 如图3所示，步骤S30包括：

[0069] S301、从规则库内的预设规则中查找与上述爬取得到的网页数据相匹配的属性种类。

[0070] 例如，爬取得到的网页数据包括PM10浓度69μg/m3、PM2.5浓度31μg/m3，则相匹配的属性种类分别为PM2.5和PM10。

[0071] S302、将上述爬取得到的网页数据的值，与上述相匹配的属性种类所关联的阈值进行比对，获得污染物浓度比对结果，即关联分析的结果。

[0072] 例如，将PM2.5浓度31μg/m3与对应的阈值30μg/m3进行比对，则比对结果为PM2.5浓度超过阈值；

[0073] 将PM10浓度69μg/m3与对应的阈值70μg/m3进行比对，则比对结果为PM10浓度未超过阈值。

[0074] 在某些实施方式中，步骤S30包括以下步骤：

[0075] 1)规则引擎读取并解析规则库，并对预设的规则进行编译加载。

[0076] 在某些实施方式中，S301包括以下步骤：

[0077] 通过规则配置端创建规则库中的预设规则，并以json格式存储在Mysql数据库中，上述规则包括：规则名称、规则编号、规则类型、规则描述、规则启用状态、规则语句、告警级
别、告警响应动作。规则除了规则语句还定义了告警级别以及告警响应动作，通过该字段为
后续安全事件自动化的处置策略配置提供了配置依据。规则引擎启动后会预先加载这部分
规则，当规则有变更时，会发送rpc消息通知规则引擎重新加载规则库以达到动态实时响应
规则变更。规则引擎从规则库中读取并解析，生成预设规则执行的有向无环图；规则引擎中
的词法语法分析器将规则有向无环图翻译成FlinkCep的java代码。

[0078] 2)将爬取得到的网页数据生成特征向量模型规则。

[0079] 在某些实施方式中，步骤S302包括：通过对爬取得到的网页数据进行特征工程计算生成训练数据和测试数据，模型训练和模型评估对训练数据和测试数据进行交叉训练评
估生成最优模型参数，从而建立特征向量模型规则。

[0080] 3)将爬取得到的网页数据生成待分析的实时事件流。

[0081] 在某些实施方式中，将爬取得到的网页数据推送到kafka消息队列中生成待分析的实时事件流。上述实时事件流为json格式数据，其定义字段包括：事件类型、事件来源、设
备互联网协议地址、事件时间、源互联网协议地址、目的互联网协议地址、日志内容以及根
据不同事件类型自定义的字段。

[0082] 4)将特征向量数据流输入到特征向量模型规则中进行模型规则匹配.

[0083] 在某些实施方式中，将步骤S302中的特征向量模型规则上线，通过在线模型预测任务，对待分析的事件流中一段事件窗口的事件数据经过特征工程计算，生成特征向量。将
上述特征向量输入到特征向量模型规则中进行分析计算。

[0084] 5)规则引擎订阅待分析的实时事件流，并将上述待分析的实时事件流与上述预设的规则进行关联规则匹配。

[0085] 关联规则匹配通过FlinkCep实现。具体地，规则引擎调用maven命令将预设规则的java代码打包成jar包，通过任务调度器将jar包提交到flink‑on‑yarn上执行关联规则匹
配。规则引擎中的事件流订阅器通过订阅待分析的实时事件流的topic数据作为FlinkCep
任务的输入流与FlinkCep规则进行实时规则匹配，一旦触发告警生成条件则将告警信息事
件输出到告警信息消息队列的topic中。

[0086] 步骤S40、根据关联分析的结果以及上述预设规则中的告警条件，生成告警信息，并向用户端发送告警信息。

[0087] 在某些实施方式中，预设规则中的告警条件可以为污染物浓度比对结果中污染物浓度超过阈值。

[0088] 例如，可以分别设置各污染物阈值如下

[0089]

[0090] 在某些实施方式中，告警信息模型包含的字段定义为：告警名称、告警类型、告警描述、告警来源、告警时间以及根据告警类型自定义的字段等。

[0091] 生成的告警信息例如可以为：

[0092] 局部高值提醒：07:00，汴京公园、龙亭公园站点PM2.5浓度分别为80ug/m3、75ug/3 3 3 3
m ，分别比全市均值(50ug/m)高出30ug/m、25ug/m ，拉高我市均值，全省排名12/15,倒排
第4名。

[0093] 污染等级上升：07:00,我市PM2.5浓度80微克/立方米，从5:00的良下滑到轻度污染；PM10浓度80微克/立方米，从5:00的良下滑到轻度污染。

[0094] 持续变差：07:00,龙亭公园站点PM2.5浓度80微克/立方米，PM10浓度70微克/立方米，从5:00起持续变差，预计3小时后污染等级会由良下滑到轻度污染；其中，预计龙亭公园
PM10浓度190微克/立方米，为全市最高。

[0095] 排名下滑：07:00,我市PM2.5浓度分别为80微克/立方米，全省排名12/15,相较于04:00(6/15)下滑了6名，各区需立即加大站点周边及外围污染源排查与管控力度。

[0096] 排名落后：07:00,我市PM2.5小时浓度分别为80微克/立方米，全省排名12/15,倒排第4名，各区需立即加大站点周边及外围污染源排查与管控力度。

[0097] 在某些实施方式中，向用户端发送告警信息包括：调用微信公众平台提供的接口向关注微信公众号的用户终端推送告警信息；或者直接将告警信息发送到用户终端例如手
机等。

[0098] 本申请实施例提供的空气质量信息的自动生成及发送方法，通过分别控制多个代理节点中的爬虫程序以大于爬取周期阈值的爬取周期登录待爬取网站，并对各待爬取网页
进行渲染，分别控制多个代理节点中的爬虫程序协同爬取各已渲染网页的数据，将爬取得
到的网页数据与规则库内的预设规则进行关联分析，根据关联分析的结果以及预设规则中
的告警条件，生成告警信息并发送，不再需要用户频繁主动登录网站来获取空气质量信息，
用户只需要被动接收空气质量信息即可，大大方便了用户得到空气质量信息。

[0099] 如图4所示，本申请的另一个实施例提供了一种空气质量信息的自动生成及发送装置，包括：

[0100] 获取模块，用于获取爬取周期阈值，爬取周期阈值是触发待爬取网站发起互联网协议封锁操作的最大周期值；

[0101] 渲染模块，用于分别控制多个代理节点中的爬虫程序以大于爬取周期阈值的爬取周期登录待爬取网站，并对待爬取网站的各待爬取网页进行渲染，得到已渲染网页；

[0102] 爬取模块，用于分别控制多个代理节点中的爬虫程序协同爬取各已渲染网页的数据；

[0103] 分析模块，用于将爬取得到的网页数据与规则库内的预设规则进行关联分析；

[0104] 告警模块，用于根据关联分析的结果以及预设规则中的告警条件，生成告警信息并发送告警信息。

[0105] 在某些实施方式中，渲染模块包括渲染单元，渲染单元用于对待爬取网站的各待爬取网页进行渲染，得到已渲染网页；渲染单元包括：

[0106] 获取子单元，用于获取待爬取网页的源代码；

[0107] 检测子单元，用于检测源代码中的元素节点是否符合预设特征要求；元素节点与待爬取网页中的素材资源对应，预设特征要求指示元素节点对应的网页素材资源在待爬取
网页中的显示效果；

[0108] 停止子单元，用于当元素节点符合预设特征要求时，停止对元素节点对应网页素材资源的渲染操作。

[0109] 在某些实施方式中，分析模块，包括：

[0110] 查找单元，用于从规则库内的预设规则中查找与爬取得到的网页数据相匹配的属性种类；

[0111] 比对单元，用于将爬取得到的网页数据的值，与相匹配的属性种类所关联的阈值进行比对，获得污染物浓度比对结果。

[0112] 在某些实施方式中，告警模块包括发送单元，发送单元用于发送告警信息；发送单元具体用于：

[0113] 调用微信公众平台提供的接口向关注微信公众号的用户终端推送告警信息；或者直接将告警信息发送到用户终端。

[0114] 本申请的另一个实施例提供了一种电子设备，包括存储器、处理器及存储在存储器上并可在处理器上运行的计算机程序，处理器执行程序，以实现上述的空气质量信息的
自动生成及发送方法。如图5所示，电子设备20可以包括：处理器200，存储器201，总线202和
通信接口203，处理器200、通信接口203和存储器201通过总线202连接；存储器201中存储有
可在处理器200上运行的计算机程序，处理器200运行计算机程序时执行本申请前述任一实
施方式所提供的空气质量信息的自动生成及发送方法。

[0115] 其中，存储器201可能包含高速随机存取存储器(RAM：Random Access Memory)，也可能还可以包括非不稳定的存储器(non‑volatile memory)，例如至少一个磁盘存储器。通
过至少一个通信接口203(可以是有线或者无线)实现该系统网元与至少一个其他网元之间
的通信连接，可以使用互联网、广域网、本地网、城域网等。

[0116] 总线202可以是ISA总线、PCI总线或EISA总线等。总线可以分为地址总线、数据总线、控制总线等。其中，存储器201用于存储程序，处理器200在接收到执行指令后，执行程
序，前述本申请实施例任一实施方式揭示的空气质量信息的自动生成及发送方法可以应用
于处理器200中，或者由处理器200实现。

[0117] 处理器200可能是一种集成电路芯片，具有信号的处理能力。在实现过程中，上述方法的各步骤可以通过处理器200中的硬件的集成逻辑电路或者软件形式的指令完成。上
述的处理器200可以是通用处理器，可以包括中央处理器(Central Processing Unit，简称
CPU)、网络处理器(Network Processor，简称NP)等；还可以是数字信号处理器(DSP)、专用
集成电路(ASIC)、现成可编程门阵列(FPGA)或者其他可编程逻辑器件、分立门或者晶体管
逻辑器件、分立硬件组件。可以实现或者执行本申请实施例中的公开的各方法、步骤及逻辑
框图。通用处理器可以是微处理器或者该处理器也可以是任何常规的处理器等。结合本申
请实施例所公开的方法的步骤可以直接体现为硬件译码处理器执行完成，或者用译码处理
器中的硬件及软件模块组合执行完成。软件模块可以位于随机存储器，闪存、只读存储器，
可编程只读存储器或者电可擦写可编程存储器、寄存器等本领域成熟的存储介质中。该存
储介质位于存储器201，处理器200读取存储器201中的信息，结合其硬件完成上述方法的步
骤。

[0118] 本申请的另一个实施例提供了一种计算机可读存储介质，其上存储有计算机程序，该程序被处理器执行，以实现上述的空气质量信息的自动生成及发送方法。

[0119] 需要说明的是：

[0120] 术语“模块”并非意图受限于特定物理形式。取决于具体应用，模块可以实现为硬件、固件、软件和/或其组合。此外，不同的模块可以共享公共组件或甚至由相同组件实现。
不同模块之间可以存在或不存在清楚的界限。

[0121] 在此提供的算法和显示不与任何特定计算机、虚拟装置或者其它设备固有相关。各种通用装置也可以与基于在此的示教一起使用。根据上面的描述，构造这类装置所要求
的结构是显而易见的。此外，本申请也不针对任何特定编程语言。应当明白，可以利用各种
编程语言实现在此描述的本申请的内容，并且上面对特定语言所做的描述是为了披露本申
请的最佳实施方式。

[0122] 类似地，应当理解，为了精简本公开并帮助理解各个发明方面中的一个或多个，在上面对本申请的示例性实施例的描述中，本申请的各个特征有时被一起分组到单个实施
例、图、或者对其的描述中。然而，并不应将该公开的方法解释成反映如下意图：即所要求保
护的本申请要求比在每个权利要求中所明确记载的特征更多的特征。更确切地说，如下面
的权利要求书所反映的那样，发明方面在于少于前面公开的单个实施例的所有特征。因此，
遵循具体实施方式的权利要求书由此明确地并入该具体实施方式，其中每个权利要求本身
都作为本申请的单独实施例。

[0123] 应该理解的是，虽然附图的流程图中的各个步骤按照箭头的指示依次显示，但是这些步骤并不是必然按照箭头指示的顺序依次执行。除非本文中有明确的说明，这些步骤
的执行并没有严格的顺序限制，其可以以其他的顺序执行。而且，附图的流程图中的至少一
部分步骤可以包括多个子步骤或者多个阶段，这些子步骤或者阶段并不必然是在同一时刻
执行完成，而是可以在不同的时刻执行，其执行顺序也不必然是依次进行，而是可以与其他
步骤或者其他步骤的子步骤或者阶段的至少一部分轮流或者交替地执行。

[0124] 以上所述实施例仅表达了本申请的实施方式，其描述较为具体和详细，但并不能因此而理解为对本申请专利范围的限制。应当指出的是，对于本领域的普通技术人员来说，
在不脱离本申请构思的前提下，还可以做出若干变形和改进，这些都属于本申请的保护范
围。因此，本申请的保护范围应以所附权利要求为准。