一种基于Kafka的电力客户数据采样方法

专利申请号：CN202211410374.1

公 开 号：CN115630111A

发 明 人：张明杰 刘鲲鹏 邓志东 杨菁 宫立华 朱龙珠 龚健 孙荣 彭渤 李艳艳 

代 理 人：北京达友众邦知识产权代理事务所(普通合伙)张超

代理机构：北京达友众邦知识产权代理事务所(普通合伙)

专利类型：发明专利

申 请 日：20230120

公 开 日：20221104

专利主分类号：G06F16/25

关 键 词：点数据 采样 电力客户 消息队列 采样系统 数据采样 字段信息 可视化系统 数字化产品 操作触发 建立联络 结果转发 目标系统 业务指标 用电客户 用电行为 运营分析 指标计算 指标数据 投送 可视化 加工 解析 转发 统计 展示 分析 

摘      要：本发明公开一种基于Kafka的电力客户数据采样方法，包括以下步骤：(1)对目标埋点的内容下定义并实施数据埋点操作；(2)用电客户操作触发产生埋点数据并与目标采样系统建立联络；(3)目标采样系统上收投送的埋点数据；(4)目标系统解析埋点数据产生目标字段信息并实时转发至Kafka消息队列；(5)依据采样到的目标字段信息，统计加工实时指标数据，并将结果转发至Kafka消息队列；(6)可视化系统实时消费Kafka消息队列，将采样到的业务指标可视化展示。本发明能够很好地解决当前电力客户数据采样处理技术中存在的埋点数据采样、加工实时指标效率低，不能高效、及时满足埋点数据采样领域的各类电力业务实时指标计算、数字化产品运营分析、电力客户用电行为分析等诸多问题与痛点。