CN113222408B 在线问诊业务监控方法、装置、设备及存储介质 （康键信息技术（深圳）有限公司）

医疗领域中，公开了一种在线问诊业务监控方源依次进行数据迁移、数据清洗和数据聚合处则分别对在线问诊监控指标数据集进行指标校2获取多个在线问诊业务指标和每个在线问诊业务指标对应的问从每个在线问诊业务指标对应的数据源信息中提取每个在线问诊业务指标对应的数照每个在线问诊业务指标对应的清洗规则对所述待处理在线问诊数据进行数据清洗操作和/或所述第二监控指标数据集组装为在线问诊监控指标数据集，并定时将所述在线问诊型数据库mysql中二进制日志文件binlog同步解析后的数据库变更数据，所述消息队列数按照每个在线问诊业务指标对应的预警规则分别对所述在线问诊监控指标数据集进标对应的发送规则消费每个异常监控指标数据对应按照每个在线问诊业务指标对应的监控指标类型对所述在线问诊监控指标数据集进通过所述终端多视角分析并显示所述在线问诊指标视从预设的指标索引表中查询多个在线问诊业务指标的名称，按照所述多按照所述每个在线问诊业务指标的唯一标识关联查询预设的配置数据表，得到将每个在线问诊业务指标和每个在线问诊业务指标对应的问诊指标关联信息存储至3从每个在线问诊业务指标对应的清洗规则中提取每个在线问诊业务指标对应的解析按照每个在线问诊业务指标对应的解析类型对所述待处理在线问诊数据进行字段分若每个在线问诊业务指标对应的字段过滤表达式不为空指标对应的字段过滤表达式对所述多个指标字段进行聚合计算，得到第一监控指标数据若每个在线问诊业务指标对应的字段过滤表达式为空值，则从每个在线问诊业务指标对应的预警规则中提取每个在线问诊业务指标对应的报警根据每个在线问诊业务指标对应的报警规则表达式分别对所述在线问诊监控指标数若所述校验结果不为预设的目标值，则确定所述校验结果中应的报警规则名称和每个在线问诊业务指标对应的报警规则内容对每个异常监控指标数从每个在线问诊业务指标对应的发送规则中获取每个在线问诊业务指标对应的发送按照每个在线问诊业务指标对应的监控指标类型确定对应的数据组问诊业务指标对应的数据组合规则分别对所述在线问诊监控指标数据集进行数据封装组将所述在线问诊指标视图数据发送至终端，通过所述终端4在终端的预设页面中，基于所述已解析的在线问诊接收所述终端发送的在线问诊业务指标配置请求，按照所述在通过预设的同步任务定时同步预设的数据源和每个在线问诊业务指标对应的监控指获取模块，用于获取多个在线问诊业务指标和每个在线问诊处理模块，用于从每个在线问诊业务指标对应的数据源信息中指标数据集和/或所述第二监控指标数据集组装为在线问诊监控指标数据集，并定时将所业务的关系型数据库mysql中二进制日志文件binlog同步解析后的数据库变更数据，所述警示模块，用于按照每个在线问诊业务指标对应的预警规则在线问诊业务指标对应的发送规则消费每个异常监控指标数显示模块，用于按照每个在线问诊业务指标对应的监控指标类型5所述至少一个处理器调用所述存储器中的所述指令，以使得所述在6[0001]本发明涉及信息安全的性能指标监控领域，尤其涉及一种在线问诊业务监控方发送规则；从每个在线问诊业务指标对应的数据源信息中提取数据源类型和数据源地址，在线问诊业务指标对应的监控指标类型对所述在线问诊监控指标数据集进行数据封装组7问诊业务指标和每个在线问诊业务指标对应的问诊指标关联信息存储至预设的内存数据址和每个在线问诊业务指标对应的清洗规则对每个在线问诊业务指标对应的数据源依次线问诊业务指标对应的数据源信息中提取每个在线问诊业务指标对应的数据源类型和数架，按照预设的数据主题和所述数据源地址从所述卡夫卡数据源中读取各在线问诊数据，按照每个在线问诊业务指标对应的清洗规则对各在线问诊数据依次进行时间段聚合计算据集异步传输至所述数据管道；在所述数据管道中将所述第一监控指标数据集和/或所述8规则名称和每个在线问诊业务指标对应的报警规则内容对每个异常监控指标数据设置对据实时绘制并显示各在线问诊业务指标数据的则。规则对每个在线问诊业务指标对应的数据源依次进行数据迁移、数据清洗和数据聚合处通过预设的消息队列按照每个在线问诊业务指标对应的发送规则消费每个异常监控指标9诊业务指标和每个在线问诊业务指标对应的问诊指标关联信息存储至预设的内存数据库用于从每个在线问诊业务指标对应的数据源信息中提取每个在线问诊业务指标对应的数诊业务指标对应的清洗规则对各在线问诊数据依次进行时间段聚合计算和数据清洗处理，个在线问诊业务指标对应的字段过滤表达式和每个在线问诊业务指标对应的自定义过滤在线问诊业务指标对应的预警规则中提取每个在线问诊业务指标对应的报警规则表达式、每个在线问诊业务指标对应的报警规则名称和每个在线问诊业务指标对应的报警规则内中存在至少一个异常监控指标数据；当所述校验结果中存在至少一个异常监控指标数据发送规则中获取每个在线问诊业务指标对应的发送方式和每个在线问诊业务指标对应的得所述在线问诊业务监控设备执行上述的在线问诊业务线问诊业务指标对应的清洗规则对每个在线问诊业务指标对应的数据源依次进行数据迁指标视图数据发送至终端，通过所述终端多视角分析并显示所述在线问诊指标视图数据。[0030]101、获取多个在线问诊业务指标和每个在线问诊业务指标对应的问诊指标关联[0033]102、从每个在线问诊业务指标对应的数据源信息中提取数据源类型和数据源地据每个在线问诊业务指标对应的清洗规则对在线问诊数据依次进行字段分割和字段聚合源或rocketmq数据源进行数据迁移和数据清洗后，得到普罗米修斯prometheus指标数据清洗规则对每个在线问诊业务指标清洗计算并发送到data-pipeline，得到prometheus指[0035]103、按照每个在线问诊业务指标对应的预警规则分别对在线问诊监控指标数据标对应的发送规则消费每个异常监控指标数据对应服务器通过prometheus组件按照每个在线问诊业务指标对应的预警规则分别对在线问诊器按照预每个在线问诊业务指标对应的发送规则中的发送方式和联系组消费消息队列中个在线问诊业务指标可具有多个报警规则。服务器可以在预设的文件目录(例如，prometheus/etc/prometheus/rules.d/)下生成预警规则。[0037]104、按照每个在线问诊业务指标对应的监控指标类型对在线问诊监控指标数据线问诊监控指标数据集进行指标校验，通过预设的消息队列按照发送规则消费警示信息；[0042]201、获取多个在线问诊业务指标和每个在线问诊业务指标对应的问诊指标关联业务监控过滤分组规则配置表monitor_business_filter_collection_rule，得到目标数据源标识和清洗规则，清洗规则主要包括过滤分组规则名称filter_collection_rule_name、过滤分组规则内容filter_collection_rule、解析类型prase_type、分隔符一标识business_id和目标数据源标识关联查询预设的业务监控数据源配置表monitor_务器根据每个在线问诊业务指标的唯一标识business_id查询预设的业务监控报警规则表monitor_business_warn_alarm_rule，得到报警规则，报警规则主要包括报警规则名称alarm_name、报警规则标识alarm_id、报警间隔alarm_interval和报警规则内容alarm_标识alarm_id联合检索预设的业务监控报警发送规则配置表monitor_business_warn_alarm_send_rule，得到发送规则，发送规则包括发送内容send_content、最近发送时刻问诊业务指标配置请求分别配置每个在线问诊业务指标对应的监控指标类型、数据源信[0046]202、从每个在线问诊业务指标对应的数据源信息中提取每个在线问诊业务指标问诊业务指标对应数据源类型1表示消息队列rocketmq数据源、每个在线问诊业务指标对[0049]其中，数据管道data-pipeline还能够在数据迁移的处理过程实现数据转换。data-pipeline定期通过服务器提供超文本传输协议(hypertexttransferprotocol，[0050]204、按照每个在线问诊业务指标对应的清洗规则对待处理在线问诊数据进行数[0051]具体的，服务器对数据源中单条在线问诊数据在内存中采用清洗规则(也就是每个在线问诊业务指标对应的清洗规则)中预先配置的数据分割方式进行分割，得到多个指标字段，服务器对多个指标字段按清洗规则中目标指标字段聚合方式(例如，直方图histogram值表达式为结束时刻与开始时刻差值end_time-start_time)或者自定义的开发每个在线问诊业务指标对应的数值表达式的优先级高于每个在线问诊业务指标对应的自=="88"&&${fig_prescription}in"2，6"。当服务器通过data-pipeline已同步清洗规则称设置为key，每个字段的值为value，得到哈希表{“out_biz__type”:88，“fig_等于"2，6"，然后服务器生成第一监控指标数据集为consult_tag{app_id＝"9225381"，夫卡数据源时，服务器通过实时流式数据处理框架storm按照预设的数据主题和数据源地算(例如，按分钟聚合计算)和每个在线问诊业务指标对应的清洗规则进行数据清洗处理，[0058]207、按照每个在线问诊业务指标对应的预警规则分别对在线问诊监控指标数据标对应的发送规则消费每个异常监控指标数据对应[0060]sum(floor(increase(tc_order_tag[1h])))by(metrics_type)/((sum(floor(increase(tc_order_tag[1h]offset1d)))by(metrics_type)+sum(floor(increase(tc_order_tag[1h]offset2d)))by(metrics_type)+sum(floor(increase(tc_order_tag[1h]offset3d)))by(metrics_type)+sum(floor(increase(tc_order_tag[1h]offset4d)))by(metrics_type)+sum(floor(increase(tc_order_tag[1h]offset5d)))by(metrics_type)+sum(floor(increase(tc_order_tag[1h]offset6d)))by(metrics_type))/6)<个在线问诊业务指标对应的报警规则内容对每个异常监控指标数据设置对应的警示信息；服务器从每个在线问诊业务指标对应的发送规则中获取每个在线问诊业务指标对应的发[0063]208、按照每个在线问诊业务指标对应的监控指标类型对在线问诊监控指标数据线问诊监控指标数据集进行指标校验，通过预设的消息队列按照发送规则消费警示信息；[0067]获取模块301，用于获取多个在线问诊业务指标和每个在线问诊业务指标对应的问诊指标关联信息，每个在线问诊业务指标对应的问诊指标关联信息包括监控指标类型、[0068]处理模块302，用于从每个在线问诊业务指标对应的数据源信息中提取数据源类[0069]警示模块303，用于按照每个在线问诊业务指标对应的预警规则分别对在线问诊在线问诊业务指标对应的发送规则消费每个异常监控指标数据[0070]显示模块304，用于按照每个在线问诊业务指标对应的监控指标类型对在线问诊线问诊监控指标数据集进行指标校验，通过预设的消息队列按照发送规则消费警示信息；[0074]获取模块301，用于获取多个在线问诊业务指标和每个在线问诊业务指标对应的问诊指标关联信息，每个在线问诊业务指标对应的问诊指标关联信息包括监控指标类型、[0075]处理模块302，用于从每个在线问诊业务指标对应的数据源信息中提取数据源类[0076]警示模块303，用于按照每个在线问诊业务指标对应的预警规则分别对在线问诊在线问诊业务指标对应的发送规则消费每个异常监控指标数据[0077]显示模块304，用于按照每个在线问诊业务指标对应的监控指标类型对在线问诊[0081]将每个在线问诊业务指标和每个在线问诊业务指标对应的问诊指标关联信息存[0084]第一处理单元3022，用于当所述数据源类型为罗马数据[0087]组装单元3025，用于在所述数据管道中将所述第一监控指标数据集和/或所述第[0089]从每个在线问诊业务指标对应的清洗规则中提取每个在线问诊业务指标对应的[0090]按照每个在线问诊业务指标对应的解析类型对待处理在线问诊数据进行字段分业务指标对应的字段过滤表达式对多个指标字段进行聚合计算，得到第一监控指标数据[0094]从每个在线问诊业务指标对应的预警规则中提取每个在线问诊业务指标对应的[0095]根据每个在线问诊业务指标对应的报警规则表达式分别对在线问诊监控指标数应的报警规则名称和每个在线问诊业务指标对应的报警规则内容对每个异常监控指标数[0098]从每个在线问诊业务指标对应的发送规则中获取每个在线问诊业务