写点什么

Athena- 贝壳流量实验平台设计与实践

  • 2019-09-25
  • 本文字数:5704 字

    阅读完需:约 19 分钟

Athena-贝壳流量实验平台设计与实践

1 引言

随着贝壳找房业务的不断增长,精细化运营显得尤为重要。为了保证每一次迭代,每一个方案能够真正得到用户的认可,为贝壳带来有效的商机转化率,我们就不得不理性对待每次功能上线,反复对比找到产品方案中的不足加以改进。基于这种需要,我们推出了贝壳找房 AB 实验平台(Athena)(以下简称 ab 平台)来为大家做产品方案的优化测试,利用实验得到的转化数据为各个业务线优化产品方案提供科学的依据。

2AB 实验

为同一个目标制定两个方案(比如两个页面),将产品的用户流量随机分割成 A/B 两组,一组实验组,一组对照组,两组实验同时运行一段时间后分别统计两组用户的表现,再将相关结果数据(比如 pv/uv、商机转化率等)进行对比,就可以科学地帮助决策。比如在这个例子里,50%用户看到 A 版本页面,50%用户看到 B 版本页面,经过一段时间的观察后,统计发现 A 版本用户转化率 30%,高于 B 版本的 20%,如此,我们就可以判定 A 版本胜出,然后将 A 版本页面推送给所有的用户。



通常网站会利用分域、分层、分桶的机制保证流量高可用以及分流的灵活性和科学性。这样做的原因有以下几点:


(1)AB 实验大多数情况下是在一定场景下进行的,我们只需要选择对应场景的流量即可,做到流量合理划分。比如某个新功能在某个城市上线,那我们的实验流量肯定是选择这个城市的用户,比如北京用户。这里就需要按照城市维度划分单个流量域,在这个流量域内进行新功能的实验。


(2)流量是有限的,但是实验的数量是可以无限扩展的。试想如果我们在链家网选择北京这个城市后,针对北京房源列表页展示做了实验一列表展示优化实验,实验二推荐算法对比实验,还有其他实验等。如果不分层,北京用户这部分流量,实验一占了 60%,实验二最多只能占到 40%,再来其他实验,只能被分到更少的流量。因此会产生实验流量饥饿的问题。在做了分层之后,每层实验之间流量互不干扰,共享 100%的流量,流量在每一层被重新打散分配。就可以支持更多的实验同时运行而不会导致流量饥饿的问题。


(3)实验的对照组和实验组之间是流量互斥的,因此需要分桶隔离,将流量随机分到不同的桶中。

3 分层实验

在整个平台介绍之前,先介绍以下 AB 实验平台设计的理论基础,这样可以方便大家理解后续的设计架构。业界的 AB 平台的设计都参考了谷歌重叠实验框架的论文:


《Overlapping Experiment Infrastructure: More, Better, Faster Experimentation》,译文可以参考:http://www.flickering.cn/uncategorized/2015/01/。我们的ab平台也是参考了其分层实验模型设计而成。

3.1 分层实验模型

作为实验平台,支持同时运行大量 AB 实验是其基本要求。多实验并行的情况下,我们根据共享同一份流量,两个实验效果是否会产生干扰,将实验之间的关系分为正交实验和互斥实验。


互斥实验:如果分层共享同一份流量就有可能出现实验效果之间相互干扰的问题,这样的实验叫互斥实验,也就是如果实验一和实验二是互斥关系,那么经过实验一的流量就不能进入到实验二。


正交实验:如果实验之间共享同一份流量实验效果之间不干扰,这样的实验我们叫正交实验,这种情况下,流经两个实验的流量是可以共享的,流经实验一的流量也可以流经实验二。


举个例子:例如实验一是 web 页面背景色,实验二是文字颜色,实验一的对照实验是蓝色,实验二的对照实验也是蓝色,如果实验一和实验二共享同一份流量,那么这部分流量就会出现一种背景色为蓝色,文字为蓝色的情况,这样的页面是不可读的,两个实验的效果就产生了干扰,这里的实验一和实验二就是互斥实验。另假设,这里实验一不变,实验二是列表页推荐算法的优化,那么页面的背景色展示和算法优化就可以共享同一份流量,经过实验一的流量到实验二的时候被重新随机打散。实验效果之间并不会产生干扰,将这样的实验我们称之为正交实验。后文还会详细讲模型如何处理这两种实验。


多实验并行过程中,既有正交实验,也有互斥实验并且要保证流量在实验过程中科学合理的分配。分层实验模型就提出了“层”的概念。层的原则是:同一层存在多个互斥实验,流量流经该层最多可以参与一个实验。层与层之间,流量是正交的,也就是说流量在穿越每一层实验时候,都会被再次随机打散,经过上层实验一的流量可能会经过下层的任何一个实 验,可能是实验二,也可能是实验三。如图:



正如之前所述,在正常的实验过程中,我们一般会从总体流量中按照一定的维度去划分一个个流量区域,来做实验,比如一部分实验做在 PC 端,一部分做在 M 端。如此,就引出了另外一个概念,“域”。这里划分出的流量池就是一个域,在这个域里还可以进行分层实验,不同域之间流量隔离,所有的流量域加起来共享 100%流量。如图:



通过域、层、实验之间的嵌套关系组合,就可以满足我们很多场景的实验,划分想要的流量域,运行想要的各种不同的实验类型。

3.2 流量分桶

模型有了,怎么分流也很重要,那么什么是分流呢?分流指的是根据分流算法策略为每层的每个实验分配相应的流量,从请求角度来说,是让每个请求都能在各层准确稳定的命中到相应实验。分流也叫流量分桶,为什么叫流量分桶呢?那首先就得说明一下这里的桶指的是什么。


这里,每一层的每个实验的实验组和对照组就是一个桶,每层的流量一共是 100,假设这一层有两个实验分别是实验一和实验二,流量配比各为 50%,每个实验各有一实验组和对照组,实验组和对照组平分流量各得 25%,那么这里每层实验就有 4 个桶。整体流量按桶划分,从 0 开始编号的话,可以认为,实验一组一的桶装的是 0~24 的编号,实验一组二的桶装的是 25~49 编号,类推,实验二组二的桶装的是 75~99 的编号。一个流量请求在每一层中只能命中到一个实验组,也就是说只能被分到一个桶内。一般我们会选择用用户 id 和实验层 id 哈希取模(mod=f(uid, layer)%100),得到的值在哪个桶内,该请求就命中哪个实验的那个组,这样 保证了用户在每层命中的实验是随机且是稳定的。

4 架构与实现

AB 平台架构主要包括 web 层、api 层、数据层、存储层,核心分流服务构成:



web 层:主要提供用户界面化的操作来配置实验,创建实验受众,创建白名单,查看实验效果等功能,其中用户配置实验过程中最重要的一部分就是实验受众。


实验受众:指的是用于实验的流量人群。目前受众分为两种,分别是基于维度标签组合形成的 AB 受众和基于用户画像标签圈定的人群包受众:


1)AB 受众:支持按照设备(ios、android)、城市、URL(比如区分贝壳 pc 和 m 站)等维度生成标签,再由标签之间组合形成各个维度的受众,比如北京安卓用户。这种受众通过解析请求的 cookie 信息,正则匹配标签内容判断是否应该进入对应受众。


2)人群包受众:因为人群包受众是通过 DMP 平台提供的用户画像标签(比如城市、最近的活跃度等)圈出来的人群 id 集合,所以也叫 DMP 受众,目前这部分受众的用户的 id 取值逻辑主要取自于设备 id。通过判断用户请求信息的设备 id 是否包含在人群 id 集合中,来判断是否应该进入到该受众。


上面提到了白名单,那么白名单是什么呢?我们可以把白名单理解为一种特殊的受众,白名单中包含了人为添加的用户 id。它一般应用于一个实验的某个实验组上,为这个实验组指定白名单,那么在对这个实验分流的时候,白名单的用户就忽略分流策略,直接命中配置了该白名单的实验组。白名单常用于测试情况下,指定测试人员命中实验组,方便测试。


配置实验受众、指定了实验起始和过期时间、配置实验组和对照组的流量之后,就可以开始实验了。配置好的实验如图:



api 层:提供业务方调用 ab 平台接口,用户请求 ab 平台的 api 时,解析请求 header 中的 cookie 信息判别受众以及获取用户 id 用于实验分流。根据实验场景不同,api 分为客户端 API 和服务端 API。


客户端 api 主要用于客户端实验比如 UI 等实验,API 请求逻辑处理如图:



服务端 API 主要用于后端逻辑优化、算法策略实验对比等,由于从前端到后端实验调用处,链路可能很长,对于请求信息的传递的保存和传递显得困难。因此,我们设计了 uniqId,当用户请求线上域名的时候,负载均衡层会生成一个唯一的 uniqId,将用户的请求信息保存到 redis,之后的请求链路中,会将 uniqid 传递给后端,该参数也是请求 ab 服务时必不可少的参数。API 逻辑如图所示:



分流服务:主要提供流量划分的功能。


分流依据:ab 平台利用用户 id 进行分流,这其中包括标记新用户或访客的 lianjia_uuid、注册用户的 lianjia_ucid、针对移动设备的 lianjia_device_id。


分流实现:基于多层实验模型的流量分桶原理,ab 平台对其做了适当的简化,以更加适合目前我们的业务需求。我们定义每层一个实验,各层之间流量正交。每个实验受众,可以理解为一个域。一个受众可以用于多个实验。


在程序设计中,我们取 map 集合,命名 traffics,将运行中的实验加载到 traffics 中,traffics 的 key 是每个实验的名字,比如 exp1,traffics 的值是 traffic,每个 traffic 也是一个 map 结构,traffic 的 key 是每个实验分组的名字,比如这里是 group1,group2。traffic 的值是每个实验组的桶内编号的集合,这里是一个 set 结构来存储。如图所示:



分流过程:



业务方通过解析得到的实验配置,控制该用户命中不同的逻辑。


数据层:将流量的实验分组信息与用户行为日志做关联,分析实验的指标数据。实验效果分析包括实时数据分析和离线数据分析,过程分别如下:


1)离线数据分析:流量分组日志实时写入到 kafka,这部分分组数据作为离线数据一部分写入到 hive 表中,与存储在 hive 表中的用户行为数据,按照用户 id 做关联,关联得到的用户在各个实验方案下的行为数据写入到 clickhouse 中。


2)实时数据分析:流量分组日志实时写入到 kafka,这部分分组数据作为实时数据写入到 hbase 中。同时,用户行为日志数据由 dig 埋点服务实时写入到行为日志的 kafka 中,spark-streaming 实时任务仍然按照用户 id 整合 kafka 中的行为日志数据和存储在 hbase 中的流量分组数据。整合之后的数据实时写入到 kafka,再由实时任务消费写入到 clickhouse。如图所示:



经过对存储在 clickhouse 中的数据通过复杂的 SQL 进行聚合分析,得到用户在相应实验方案下的 pv、uv、转化等数据。效果如图所示:



实验概况图



实验转化图


存储层:AB 平台的存储层主要包括:


(1)mysql:用于保存实验配置、白名单配置、实验受众信息。


(2)Hbase:存储用户命中 AB 实验分组信息,用于实时处理的分组日志数据整合。


(3)redis:借助其高性能的数据写入和读取特性,用于存储和用户请求分流直接相关的 uniqId 对应的 cookie 信息、白名单包含的用户 id、人群包包含的用户 id 集合,保证请求分流能够 1-2 毫秒内快速高效完成。


(4)clickHouse:这是一款能够支持十亿级日志数据秒级自定义分析的查询引擎,其高效的存储性能以及丰富的数据聚合函数成为实验效果分析的不二选择。离线和实时整合后的用户命中的实验分组对应的行为日志数据最终都导入了 clickhouse,用于计算用户对应实验的一些埋点指标数据(主要包括 pv、uv)。


关于 clickhouse,如果有兴趣,可以了解之前发表过的 clickhouse 实践文章:ClickHouse Practice。

5 灰度发布

灰度发布:是指在黑与白之间,能够平滑过渡的一种发布方式。AB test 就是一种灰度发布方式,让一部分用户继续用 A,一部分用户开始用 B,如果用户对 B 没有什么反对意见,那么逐步扩大范围,把所有用户都迁移到 B 上面来。灰度发布可以保证整体系统的稳定,在初始灰度的时候就可以发现、调整问题,以保证其影响度。(百度百科)


灰度实现思路:当某个实验效果非常好时,可以动态调整该实验的流量占比,从而迅速得到收益,并且在大流量上验证该实验的有效性。一旦确认该实验效果非常良好,便可以在全流量上线。由于目前 AB 仅支持 Http 接口调用,在某些高并发场景下,业务方希望使用 SDK 来避免网络 IO 的性能消耗,因此该功能基于 SDK 实现(目前只支持 java 程序调用)。


灰度发布 SDK:


(1)拉取配置:调用方集成 SDK 之后,SDK 会每隔一分钟拉取 AB 平台的所有实验分流配置到本地,保证调用方要用的配置是最新的。


(2)根据灰度发布实验的名字,获取该实验的分桶配置,也就上在分流模型中说的 traffic。


(3)根据实验名字和用户 id 进行 hash,r = HashUtil.hash(uuid, expName),获取在灰度实验中命中的实验组。


自定义参数功能:自定义参数可以为用户在不同的实验方案下指定不同的参数取值。比如灰度发布实验中,可以指定版本号为自定义参数,为不同的实验组设置不同的版本号。如此,流量命中实验组之后可以直接得到得到具体的版本号信息,方便控制版本发布。

6 业务支持情况

AB 实验平台目前已经有多个部门接入使用,累计运行实验近百个,已支持并行运行实验 40+。

7 实践效果

AB 实验平台利用统计数据在很多场景下指导算法策略以及产品方案的优化方向。下图是算法策略部门在 AB 实验平台上进行进行的贝壳首页推荐策略 A/B 实验。横轴是实验时间,纵轴是 CTR,利用 ab 平台划分 6 个实验组,根据实验方案下的指标数据得出 CTR 的表现情况,为方案优化提供数字依据。


8 不足

虽然目前的实验平台已经具备了一部分功能,可以满足大部分实验需求。但是,我们的实验平台相比业界的很多平台还有不足。包括以下方面:


(1)实验效果解读不够直观易懂,暂时缺乏置信区间等统计数据辅助决策。


(2)基于层的实验划分支持不完善,目前只支持多层正交实验,对互斥实验支持度不够。


(3)灰度发布功能有很大的局限性,目前的方式业务代码耦合度高。

9 展望

首先以上的不足将是我们努力的方向,后续会不断探索优化平台。很期待大家在产品迭代方案选择上优先利用 ab 平台走 AB 测试,在项目上线前利用 ab 平台优先走灰度发布。希望借助于 AB 测试,利用灰度发布形成一套结合 AB 测试的开发上线流程:需求评审-建立试验方案-新功能开发-灰度发布-小流量 AB 测试-发布成功的功能,关闭失败的。也期待大家多提宝贵的意见与建议,以便于我们提供更好的平台服务。


作者介绍:


雏鹰(企业代号名),目前负责贝壳找房增长方向 AB 实验平台研发工作。


本文转载自公众号贝壳产品技术(ID:gh_9afeb423f390)。


原文链接:


https://mp.weixin.qq.com/s/1OoZhDjwRWfMxHzLazUr0w


2019-09-25 23:582478

评论

发布
暂无评论
发现更多内容

进军东南亚!Coremail泰国分公司启航

科技热闻

Java程序员如何进一步学习netty?

了不起的程序猿

Java Netty 架构师 java编程

局域网企业网盘:主流的8大厂商产品对比

爱吃小舅的鱼

阿里巴巴热卖商品推荐API接口的获取与应用

科普小能手

阿里巴巴 电商 API API 接口 阿里巴巴数据采集

面基超快乐!和鲸社区亮相 PyCon China 2024 社区展

ModelWhale

Python 数据挖掘 机器学习 深度学习 数据库

MPC2024明道云伙伴大会圆满结束

明道云

法行宝爱企查AI形象上线,AI版“职场搭子”度律度秘替你打工

科技热闻

华中科技大学鲲鹏昇腾科教创新孵化中心揭牌,产学研合作再结硕果

Geek_2d6073

模型输出可保存为数据集、支持配置社区活动作为课程作业|ModelWhale 版本更新

ModelWhale

Python 人工智能 数据分析 元数据

InfluxDB vs TDengine :2025 年了,谁家用的数据库还不能高效读缓存?

TDengine

数据库 tdengine 时序数据库

如何设计一个高并发系统?

开心学Java

Java 程序员 高并发 架构师 架构师设计

HarmonyOS 5.0应用开发——装饰器的使用

高心星

huawei HarmonyOS HarmonyOS NEXT

项目经理如何向客户更好地汇报项目情况

Hi-CodeCaptain

项目管理 软件测试 精准测试 代码覆盖率 质量内建

如何通过ETLCloud做企业级数据集成

RestCloud

数据分析 ETL 数据集成 企业数据集成

揭秘1688阿里巴巴API接口:解锁商品评论与描述详情图的深度探索之旅

代码忍者

API 接口 pinduoduo API

TiDB 关联子查询及半连接的优化实践

PingCAP

数据库 #TiDB

工业 5.0 时代的数字孪生:迈向高效和可持续的智能工厂

Altair RapidMiner

工业 制造业 数字孪生 仿真 altair

体育赛事直播系统二次开发指南,助力平台提高竞争力

软件开发-梦幻运营部

夜莺短信告警教程

巴辉特

夜莺监控 夜莺Nightingale 夜莺短信告警

TDengine vs InfluxDB:谁的“流式计算”功能是真的?

TDengine

数据库 tdengine 时序数据库

为什么现在Java面试基本都要考察底层源码内容?

开心学Java

高并发 jdk源码 架构师 java面试 Java多线程

TikTok直播网络要求是什么?

Ogcloud

TikTok tiktok直播 tiktok直播专线 tiktok直播网络 tiktok直播加速

从微软 SSAS 到国产替代,这家企业终于松了一口气

Kyligence

ERP系统实施的难点不是系统本身,而是企业的人与管理

积木链小链

企业管理 ERP 中小企业

2024最新Spring全家桶进阶笔记全网首次开源

了不起的程序猿

Java spring 微服务 架构师 Spring全家桶

用例图如何在线制作?10个用例图模板案例推荐!

职场工具箱

效率工具 UML 用例图 在线白板 绘图软件

集团总部与分公司组网:选择MPLS还是SD-WAN?

Ogcloud

SD-WAN 企业组网 企业网络 SD-WAN组网 SD-WAN服务商

《可观测性体系建设100问》第二章—可观测性技术应用正式发布!实战应用,深化理解

博睿数据

星闪与Wi-Fi 7一相逢,便点亮智家无数

脑极体

AI

实战丨证券 HTAP 混合业务场景的难点问题应对

PingCAP

数据库 #TiDB

活动回顾丨云原生开源开发者沙龙·杭州站回放 & PPT 下载

阿里巴巴云原生

阿里云 云原生

Athena-贝壳流量实验平台设计与实践_文化 & 方法_尤达_InfoQ精选文章