A general-purpose streaming big data statistics system.
Easier to use, supports a larger amount of data, and can complete more statistical indicators faster.
一键部署，一行代码接入，无需大数据研发运维经验，轻松驾驭海量数据实时统计。
- 1、再也不需要用Flink、Spark、ClickHouse或者基于Redis这种臃肿笨重的方案跑数了；
- 2、再也不需要疲于应付对个人价值提升没有多大益处的数据统计需求了，能够帮助您从琐碎反复的数据统计需求中抽身出来，从而专注于对个人提升、对企业发展更有价值的事情；
- 3、轻松帮您实现任意细粒度的监控指标，是您监控服务运行状况，排查各类业务数据波动、指标异常类问题的好帮手；
- 4、培养数据思维，辅助您将所从事的工作建立数据指标体系，量化工作产出，做专业严谨的职场人，创造更大的个人价值；
- XL-LightHouse是针对互联网领域繁杂的流式数据统计需求而开发的一套集成了数据写入、数据运算、数据存储和数据可视化等一系列功能，支持超大数据量，支持超高并发的【通用型流式大数据统计平台】。
- XL-LightHouse目前已涵盖了各种流式数据统计场景，包括count、sum、max、min、avg、distinct、topN/lastN等多种运算，支持多维度计算，支持分钟级、小时级、天级多个时间粒度的统计，支持自定义统计周期的配置。
- XL-LightHouse内置丰富的转化类函数、支持表达式解析，可以满足各种复杂的条件筛选和逻辑判断。
- XL-LightHouse是一套功能完备的流式大数据统计领域的数据治理解决方案，它提供了比较友好和完善的可视化查询功能，并对外提供API查询接口，此外还包括数据指标管理、权限管理、统计限流等多种功能。
- XL-LightHouse支持时序性数据的存储和查询。
- XL-LightHouse面向企业繁杂的流式数据统计需求，可以帮助企业在极短时间内快速实现数以万计、数十万计的数据指标，而这是Flink、ClickHouse之类技术所远不能比拟的，XL-LightHouse帮助企业低成本实现数据化运营，数据指标体系可遍布企业运转的方方面面；
- 对单个流式统计场景的数据量无限制，可以非常庞大，也可以非常稀少，您既可以使用它完成十亿级用户量APP的DAU统计、十几万台服务器的运维监控、一线互联网大厂数据量级的日志统计、也可以用它来统计一天只有零星几次的接口调用量、耗时状况；
- 支持高并发查询统计结果；
- 一键部署、一行代码接入，无需专业的大数据研发人员，普通工程人员就可以轻松驾驭；
- 有完善的数据指标可视化以及数据指标管理维护等功能；
完整版使用示例请查阅：HelloWorld
该区域包含3个Tab，每个Tab有多个业务ICON图标，用户手动滑动可切换Tab，假设针对该ICON区域我们有如下数据指标需求：
点击量：
1、每5分钟_点击量
2、每5分钟_各ICON_点击量
3、每小时_点击量
4、每小时_各ICON_点击量
5、每天_总点击量
6、每天_各Tab_总点击量
7、每天_各ICON_总点击量
点击UV:
1、每5分钟_点击UV
2、每小时_点击UV
3、每小时_各ICON_点击UV
4、每天_总点击UV
5、每天_各ICON_总点击UV
- 定义元数据结构：
| 字段 | 字段类型 | 描述 | |
|---|---|---|---|
| user_id | string | 用户标识 | |
| tab_id | string | Tab栏 | tab1、tab2、tab3 |
| icon_id | string | 美食团购、酒店民宿、休闲玩乐、打车 ... |
- 上报元数据时机
用户点击ICON图标时上报相应埋点数据
- 配置统计项
- 查看统计结果
- 统计需求梳理
订单量：
1、每10分钟_订单量
2、每10分钟_各商户_订单量
3、每10分钟_各省份_订单量
4、每10分钟_各城市_订单量
5、每小时_订单量
6、每天_订单量
7、每天_各商户_订单量
8、每天_各省份_订单量
9、每天_各城市_订单量
10、每天_各价格区间_订单量
11、每天_各应用场景_订单量
交易金额：
1、每10分钟_成交金额
2、每10分钟_各商户_成交金额top100
3、每10分钟_各省份_成交金额
4、每10分钟_各城市_成交金额
5、每小时_成交金额
6、每小时_各商户_成交金额
7、每天_成交金额
8、每天_各商户_成交金额
9、每天_各省份_成交金额
10、每天_各城市_成交金额
11、每天_各应用场景_成交金额
下单用户数：
1、每10分钟_下单用户数
2、每10分钟_各商户_下单用户数
3、每10分钟_各省份_下单用户数
4、每10分钟_各城市_下单用户数
5、每小时_下单用户数
6、每天_下单用户数
7、每天_各商户_下单用户数
8、每天_各省份_下单用户数
9、每天_各城市_下单用户数
10、每天_各价格区间_下单用户数
11、每天_各应用场景_下单用户数
- 定义元数据
| 字段 | 字段类型 | 描述 | |
|---|---|---|---|
| userId | string | 用户ID | |
| orderId | string | 订单ID | |
| province | string | 用户所在省份 | |
| city | string | 用户所在城市 | |
| dealerId | string | 商户ID | |
| scene | string | 支付场景 | 电商、外卖、餐饮、娱乐、游戏 ... |
| amount | numeric | 订单金额 |
- 消息上报时机
用户支付成功后上报原始消息数据。
- 配置统计消息
我这里假设订单有四种状态：支付成功、支付失败、超时未支付、订单取消。
订单量：
1、每10分钟_各状态_订单量
2、每10分钟_各商户_各状态_订单量
1、每天_各状态_订单量
2、每天_各商户_各状态_订单量
订单异常率:
1、每10分钟_订单异常率
2、每10分钟_各商户_订单异常率
3、每小时_订单异常率
4、每天_订单异常率
5、每天_各商户_订单异常率
支付失败用户数统计:
1、每5分钟_支付失败用户数
- 定义元数据
| 字段 | 字段类型 | 描述 | |
|---|---|---|---|
| userId | string | 用户ID | |
| province | string | 用户所在省份 | |
| city | string | 用户所在城市 | |
| dealerId | string | 商户ID | |
| orderId | string | 订单ID | |
| state | string | 订单支付状态 | 1:支付成功、2：支付失败、3：超时未支付 4：订单取消 |
- 配置统计项
- 查看统计结果
- 资讯类场景使用演示 dtstep.com/archives/4262.html
- 电商类场景使用演示 dtstep.com/archives/4286.html
- 即时通讯类场景使用演示 dtstep.com/archives/4291.html
- 技术类场景使用演示 dtstep.com/archives/4298.html
为保障创作者的合法权益以及支持XL-LightHouse项目的发展，本项目在Apache2.0开源协议的基础上，增加如下补充条款，如果以下条款与Apache2.0协议内容有所冲突，以该补充条款为准。
- 1、企业或机构内部使用XL-LightHouse源程序不受任何限制，但不可删除源程序中的版权声明等信息。
- 2、企业、机构或个人销售XL-LightHouse相关软硬件产品或服务需向原作者支付一定比例的授权费用。所述的“服务”指为购买者提供统计数据类服务或提供相应产品的技术支持维护服务，在销售相关产品或服务前请您查阅【版权声明】。
- 资讯类场景使用演示 dtstep.com/archives/4262.html
- 电商类场景使用演示 dtstep.com/archives/4286.html
- 即时通讯类场景使用演示 dtstep.com/archives/4291.html
- 技术类场景使用演示 dtstep.com/archives/4298.html
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent