一文读懂字节跳动“埋点验证平台”[通俗易懂]

一文读懂字节跳动“埋点验证平台”[通俗易懂]更多技术交流、求职机会、试用福利,欢迎关注字节跳动数据平台微信公众号,回复【1】进入官方交流群 序言 埋点数据作为推荐、搜索、产品优化的基石,其数据质量的重要性不言而喻,而要保障埋点数据的质量,埋点验

一文读懂字节跳动“埋点验证平台”

更多技术交流、求职机会、试用福利,欢迎关注字节跳动数据平台微信公众号,回复【1】进入官方交流群

 

序言

埋点数据作为推荐、搜索、产品优化的基石,其数据质量的重要性不言而喻,而要保障埋点数据的质量,埋点验证则首当其冲。工欲善其事必先利其器,要做好埋点验证会面临很多技术挑战:易用性、准确性、实时性、稳定性、扩展性,如何攻克这些挑战呢,其实还是技术,这也是本文的主旨所在。

目前埋点验证已在字节内部得到广泛使用,通过一键扫码开启验证、实时上报验证、自动生成验证报告,解决了埋点数据验证难、埋点质量保障难的问题。

埋点验证流程

  • 埋点生命周期:4+6

    4 个角色:PM、DA、RD、QA

    6 个节点:提出需求、设计埋点、开发埋点、测试埋点、上报埋点、分析埋点

  • 埋点验证流程:3+3+3

    3 个角色:DA、RD、QA

    3 个节点:设计埋点、测试埋点、验收埋点

    3 个物料:埋点验证方案、埋点验证工具、埋点验证报告

图片

技术架构

产品流程

先简单介绍一下产品,以便大家能对平台有整体认识,方便大家更加轻松地理解技术,平台主要包括三部分:埋点验证方案、埋点验证工具、埋点验证报告,三者相辅相成,极大的降低了用户的埋点验证成本。

图片

  • 附埋点验证工具图

图片

技术架构图

埋点验证的链路很长,可以简单概括为三个环节:埋点上报、埋点接收、埋点验证,每个环节都有一定的复杂性,此处先介绍整体流程,让大家可以快速对全流程有所认识。其次将主要聚焦于“埋点验证”环节,此环节的重中之重是埋点验证引擎,它包括 4 个部分:规则生成器、规则选择器、埋点验证器和埋点推送器,通过对埋点验证引擎的详解让大家对“埋点如何验证”有更深的理解。

  • 埋点上报环节重点是丰富的 SDK(客户端、服务端、JS、Chrome 插件),要做到简单易用并且保证埋点实时上报。

  • 埋点接收环节重点是数据接收服务(客户端-applog、Web 端-mcs、服务端-databus)、数据保存服务(消息队列),要保证服务稳定并且保证埋点不丢失。

  • 埋点验证环节重点是埋点验证引擎,要确保服务高性能并且保证埋点验证结果的准确性。

图片

规则生成器

规则生成器将“埋点验证方案”转换为“验证规则”。埋点验证方案是验证规则的逻辑视图,方便用户操作,降低验证规则的编写和维护成本。通过逻辑视图和物理视图两层逻辑,确保了埋点验证引擎底层不受业务变化的影响。

图片

埋点方案

埋点验证方案支持 2 种:

  • 按需求验证:即新建需求计划,针对某次需求验证、

  • 按元数据验证:即按元数据验证,元数据是指所有需求的并集

按元数据验证:

  • 埋点名称:video_play

  • 参数信息

    (名称、类型、是否必填、值校验、是否是场景条件)

    enter_from,string,必传,固定值(login),是

    duration,integer,必传,值无限制,否

    type,integer,必传,枚举(1,2,3),否

埋点数据:

{
    "app_id":100,
    "event":"click",
    "params":{
        "enter_from":"login",
        "duration":1,
        "type":3
    }
}

埋点规则

{
    "app_id":100,
    "event_name":"video_play",
    "logical_filter":{
        "enter_from":"login"
    },
    "meta":{
        "required_field":[
            "duration",
            "enter_from",
            "type"
        ],
        "scene":{
            "condition":"enter_from=login",
            "name":"登录页"
        },
        "validate_field":[
            "duration",
            "enter_from",
            "type"
        ]
    },
    "physical_validation":"{"$schema":"https://json-schema.org/draft/2019-09/schema","type":"object","properties":{"params":{"type":"object","properties":{"duration":{"type":"integer"},"enter_from":{"type":"string","enum":["login"]},"type":{"type":"integer","enum":[1,2,3]}},"required":["duration","enter_from","type"]}},"required":["params"]}",
    "source":"schema_scene"
}

埋点规则字段说明

  • app_id:应用 id

  • event_name:埋点名称

  • logical_filter:用于“规则选择器”

  • physical_validation:用于“埋点验证器”

  • source:区分规则来源:按需求验证、按元数据验证

规则选择器

规则选择器将依据“埋点”中的关键信息,从“验证规则池”中选择出对应的“埋点验证规则”。

  • 选择逻辑:具体数据参考“规则生成器”

    根据“埋点数据”中 app_id 和 event 从“验证规则池”中筛选出“匹配的规则”

    将“埋点数据”的 parms 字段和“匹配的规则”的 login_filter 规字段进行匹配,选择出最终的“埋点验证规则”

 

图片

埋点验证器

埋点验证器将依据“基础验证规则”以及“规则选择器”产出的“埋点验证规则”,对“埋点数据”进行验证并产出“验证结果”。

  • 基础验证规则:埋点是否登记;埋点是否禁用;是否是 debug 埋点;

  • 埋点验证规则:参数是否丢失;参数类型是否正确;参数取值是否符合预期:枚举、范围、正则;

  • 埋点验证结果:验证结果提供双语格式,用户可自行选择中文或者英文;

图片

埋点推送器

埋点推送器将“埋点验证结果”推送到前端,推送的过程存在数据交互频繁、数据体积大、数据传输稳定性的要求,这里我们自建 Push 服务进行数据传输,保证数据实时可达。

图片

技术挑战

  • 易用性:快速接入埋点验证,快速开始埋点验证

  • 准确性:埋点验证结果准确、用户可信

  • 实时性:埋点数据实时可见

  • 稳定性:埋点数据可靠不丢失

  • 扩展性:快速接入新的埋点数据格式

易用性

快速接入埋点验证,快速开始埋点验证

SDK

  • 快速接入埋点验证

  • SDK 提供“埋点验证开关”,客户端集成 SDK 的时候,可根据不同环境来配置是否开启“埋点验证开关”

  • SDK 层判断如果开启“埋点验证开关”,埋点数据会双发,此过程对业务是透明的

    双发的原因或者为什么不从“线上埋点通道”取数?这里主要考虑两个原因:

    “线上埋点通道”数据量太大

    SDK 层线上上报逻辑是采用微批的形式,默认 1 分钟从客户端上报一次,而埋点验证要求实时性,所以采用单独的通道

图片

 

图片

准确性

埋点验证结果准确、用户可信

埋点验证引擎必须保证埋点验证结果的准确性,才能降低验证成本。针对埋点数据本身的格式验证,我们采用了 JsonSchema 作为验证手段,以支持完善的验证规则、可信的验证结果。上文中的“规则生成器”、“规则选择器”、“埋点验证器”也都在一定程度上保证了埋点验证结果的准确性。

埋点方案

event:video_play

  • 埋点名称:video_play

  • 参数信息

    (名称、类型、是否必填、值校验、是否是场景条件)

    enter_from,string,必传,固定值(login),是

    duration,integer,必传,值无限制,否

    type,integer,必传,枚举(1,2,3),否

埋点规则

jsonSchema

{
    "$schema":"https://json-schema.org/draft/2019-09/schema",
    "type":"object",
    "properties":{
        "params":{
            "type":"object",
            "properties":{
                "duration":{
                    "type":"integer"
                },
                "enter_from":{
                    "type":"string",
                    "enum":[
                        "login"
                    ]
                },
                "type":{
                    "type":"integer",
                    "enum":[
                        1,
                        2,
                        3
                    ]
                }
            },
            "required":[
                "duration",
                "enter_from",
                "type"
            ]
        }
    },
    "required":[
        "params"
    ]
}

埋点数据

event:video_play

{
    "app_id":100,
    "event":"click",
    "params":{
        "enter_from":"login",
        "duration":1,
        "type":3
    }
}

验证结果

event:video_play

图片

 

图片

  • 测试地址:https://www.jsonschemavalidator.net/

实时性

埋点数据实时可见

埋点验证场景下,服务端和验证平台需要频繁地进行数据交互,所以我们自建了 Push 服务(基于 WebSocket 的封装),能够保证数据的实时畅通性

Push 服务目标

  1. 基于 WebSocket 实现一套通用长连接通讯协议,能实现同一个客户端上的不同业务共享同一个长连接通道,并实现可靠的心跳机制。

  2. 客户端和服务端基于通用长连接通讯协议实现一个稳定可靠的全双工通道。

  3. 客户端实现一个通用的 SDK,服务端实现一个通用接入层。

  4. 客户端 SDK,服务端接入层,都要很方便后续 service 接入。

  5. Push 服务定期做打点监控,同时开放 http 的 Admin 接口,方便系统的监控和查看服务状态

Push 服务优势

  1. 连接稳定性:Push 服务分为两个组件 Push 和 Backone,实现了业务和推送解耦。push 面向客户端连接,设计尽可能简单,需保持大量客户端活跃连接,避免了业务服务更新时不影响客户端连接

  2. 服务隔离性:不同的业务服务接入 push 服务,会根据接入信息做集群隔离,避免业务之间互相影响

  3. 横向扩展性:当业务服务不断增多时,只需对 push 服务做横向扩容即可支持

Push 服务流程

图片

稳定性

埋点数据可靠不丢失

SLA

  1. 定义:服务级别协议 (service-level agreement,即 SLA) 是服务提供方与客户之间的正式承诺,用来量化服务水平(质量、可用性、责任)

  2. 埋点验证服务:服务的特征是实时,所以衡量埋点验证不可用的手段是“数据延迟”,即埋点从“上报”->“验证平台”的 p99 超过 3s 即视为不可用,日常 p99 在 1s

措施

  • 为了保证“SLA”,我们做了一系列的保护措施

  • 日志转换器:客户端、服务端、web 端上报的是原始日志格式,需要转换为埋点验证日志格式后进行验证

图片

扩展性

快速接入新的埋点数据格式

  • 提供可插拔的“日志转换器插件”,服务高内聚,可支持各种日志格式快速接入、验证

图片

展望

埋点验证是保障埋点质量的有效方式,此方式属于事前验证,适用于埋点频繁变化的业务场景,需要一定程度的人工介入,能够解决基本的埋点质量问题。但是对于核心埋点场景来说,这种方式的验证成本较高,需要重复的人力投入,为了解决核心埋点验证成本高的问题,我们正在探索落地其他方式:

  • 回归验证(自动化验证):伴随每次发版,核心埋点都需要进行回归验证,目前我们通过内部其他团队的合作实现了自动化验证功能来支撑回归验证,当前已有一部分业务正在使用,极大地降低了验证核心埋点的成本

  • 事后验证:经过事前验证、回归验证,埋点质量基本能得到很好的保障。但为了更好的保障我们也在探索事后验证的场景和落地:

    质量大盘:通过“规则引擎”,结合“质量模型”对埋点数据进行质量评估,得出各个维度的“质量评分”,然后针对质量问题进行专项修复,进一步提高埋点质量。

    质量工具:提供监控计划,业务可以针对自己关注的埋点配置监控报警,当线上出现质量问题,会发送质量报告给业务,及时止损。

  • 全链路埋点质量保障:事前验证、回归验证、事后验证贯穿埋点的生命周期,打通这三个流程,从而形成埋点质量保障全链路,彻底解决埋点质量问题。

 

立即跳转火山引擎大数据研发治理套件产品官网了解详情!

原文地址:https://www.cnblogs.com/bytedata/archive/2022/08/08/16561790.html

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。
转载请注明出处: https://daima100.com/4918.html

(0)
上一篇 2023-05-30
下一篇 2023-05-30

相关推荐

  • Python展示当前时间

    Python展示当前时间Python是一种简单易学的编程语言,并且拥有广泛的应用领域。在Python中,展示当前时间是一种极其常见的操作,也可以作为入门级别的练手小程序。展示当前时间代码简单易懂,容易传达给读者。

    2024-07-24
    41
  • 在Windows上安装MySql「建议收藏」

    在Windows上安装MySql「建议收藏」 下载压缩包 https://downloads.mysql.com/archives/community/ 解压,添加my.ini [mysqld] basedir=C:mysql-8.0….

    2023-03-23
    172
  • [离线计算-Spark|Hive] HDFS小文件处理[亲测有效]

    [离线计算-Spark|Hive] HDFS小文件处理[亲测有效]本文主要介绍小文件的处理方法思路,以及通过阅读源码和相关资料学习hudi 如何在写入时智能的处理小文件问题新思路.Hudi利用spark 自定义分区的机制优化记录分配到不同文件的能力,达到小文件的合并

    2023-05-05
    162
  • Python Class:定义和使用类来组织代码

    Python Class:定义和使用类来组织代码Python是一种简单易学的编程语言。使用Python开发应用程序,涉及到的代码量往往比其他语言要少,提高了程序的开发效率。在Python中,类是一种非常重要而且强大的机制,它可以帮助开发者组织代码并且降低代码的重复性。类的使用方式类似于其他面向对象的编程语言,比如Java、C++等。

    2024-01-20
    100
  • 关于连接服务器redis的教程「终于解决」

    关于连接服务器redis的教程「终于解决」第一步:下载RedisDesktopManager 这个百度一搜就有了,但是现在的版本ssh用不了 建议找可以用的版本,这个百度,懂得都懂。 #第二步:服务器宝塔redis设置 在配置文件将bind

    2023-04-23
    138
  • Redis 的持久化[通俗易懂]

    Redis 的持久化[通俗易懂]原文链接: https://www.changxuan.top/?p=1386 Redis 是一个非关系型的内存数据库,使用内存存储数据是它能够进行快速存取数据的原因之一。 在实际应用中,常

    2023-04-15
    163
  • Python新手必学的第一条命令——print()

    Python新手必学的第一条命令——print()在python中,print()函数用来输出内容到控制台或文件中,是Python的核心命令之一。下面是一些常见的print()函数的用法:

    2024-03-04
    87
  • day07-1MySQL约束「终于解决」

    day07-1MySQL约束「终于解决」MySQL约束 基本介绍 约束用于确保数据库的数据满足特定的商业规则 在mysql中,约束包括:not null,unique,primary key,foreign key 和check 5种 1.

    2023-06-08
    142

发表回复

您的电子邮箱地址不会被公开。 必填项已用*标注