V2EX = way to explore
V2EX 是一个关于分享和探索的地方
现在注册
已注册用户请  登录
V2EX 提问指南
binjjam
V2EX  ›  问与答

日千万级记录的 OLAP,大家用 MySQL 还是 Druid.io 还是有其他好东西?

  •  1
     
  •   binjjam · 2017-05-29 17:31:45 +08:00 · 6048 次点击
    这是一个创建于 2744 天前的主题,其中的信息可能已经有所发展或是发生改变。
    有个日志埋点接收服务,每天大概有 1500W 的请求,需要每 5 分钟进行一些聚合,原始数据大概是 16 个维度,然后取出其中的 5 个左右进行单独聚合。之前使用的是 Percona 的 MySQL 5.5,MyISAM 引擎按天进行表分区,由于每 5 分钟只聚合该 5 分钟内的数据,所以数据量也不多,统计不会有什么问题。
    然后有个老哥提出,需要每 5 分钟统计一次当天 0 点到统计时刻的情况,其实就是把原先 5 分钟内的数据统计扩大到 5 分钟到一整天 这样的一个情况,大致相当于到了每天的 20 点后,数据量都是比较大的,然后用 MySQL 的问题就体现出来了,group by 的时候会等很久,大概有个 2 分钟以上,因为统计的任务比较多,导致无法再 5 分钟内进行完所有统计。
    于是就进行了各种调研,发现有个叫 Druid.io 的玩意专门用来玩实时 OLAP 的,不过鄙人测试了下,并没有快到哪里去,一方面是因为 queryGranularity 我是按秒的,另外一方面可能是我的服务器不行( Intel(R) Xeon(R) CPU X5650 @ 2.67GHz 64G RAM ) 。
    最近我又搞了个 10.2.6-MariaDB,相同的配置下,比 Percona 的要稍快一点,但是依旧无法避免这个需要聚合千万条数据的问题。之前也测试过 InfoBright,由于我那些列基本上都是每行全满的,用了 brighthouse 发现并没有比原先的 MyISAM 快多少,所以就放弃这个了。
    不知道各位大侠在这方面是怎么做的?像 bugly 那种那么多数据不知道怎么统计才比较快?
    第 1 条附言  ·  2017-05-29 19:03:52 +08:00
    补充说明下,统计主要是统计去重用户这些,比如说 00:00~00:05 用户 A 出现了不管多少次,这 5 分钟内,去重统计的话他也只算 1 次,然后如果 00:05~23:59 他又出现了不管多少次,那么在这一天内他也只算一次。
    曾经也用 redis 的 set 来去重,这个的话是可以的,不过比较占内存而且都要自己实现,比较麻烦;而 Hyperloglog 的话,druid.io 在设计表结构的时候就可以指定某些字段进行这个聚合,快确实是快,不过不是很准( redis 的 Hyperloglog 准些)
    11 条回复    2017-05-29 21:09:45 +08:00
    misaka19000
        1
    misaka19000  
       2017-05-29 17:35:11 +08:00 via Android
    ELK ?
    binjjam
        2
    binjjam  
    OP
       2017-05-29 18:14:12 +08:00
    @misaka19000 ELK 在聚合方面也比较抓鸡
    billlee
        3
    billlee  
       2017-05-29 18:19:46 +08:00
    程序逻辑能不能改进?比如聚合 0 - 10 分钟的数据的时候,能否复用 0-5 分钟的聚合结果?
    hellommd
        4
    hellommd  
       2017-05-29 18:33:10 +08:00 via iPhone
    把每 5 分钟的结果聚合在一起?
    binjjam
        5
    binjjam  
    OP
       2017-05-29 19:09:16 +08:00
    @billlee 之前尝试过放在 redis 里面,是可以做到这点的,就是原始日志入库的时候都丢那些需要统计的到 redis 里,然后到点再从 redis 里取出来,因为统计可能不够及时,没办法直接一天放一个 set (不然可能进去的结果已经是包含了下个 5 分钟的数据了),当时搞的是 5 分钟 1 个 key,然后取并集的做法,不够需要维护很多很多 key 呢,比较麻烦~
    可能我这个套路不科学
    binjjam
        6
    binjjam  
    OP
       2017-05-29 19:10:16 +08:00
    @hellommd 去重统计的话,一天内每个 5 分钟的结果加起来并不是这一天的总去重结果呢
    mkstring
        7
    mkstring  
       2017-05-29 19:50:06 +08:00
    为啥不用 hive
    ihuotui
        8
    ihuotui  
       2017-05-29 19:50:18 +08:00 via iPhone
    应该尝试流式计算,基于静态数据再统计这种方式 实时性不好
    binjjam
        9
    binjjam  
    OP
       2017-05-29 20:15:54 +08:00
    @ihuotui 流式计算老哥能指点一二么,druid.io 这个也算是流..数据从 kafka 到 druid.io 然后再自己去拿结果。
    billlee
        10
    billlee  
       2017-05-29 20:46:49 +08:00
    @binjjam #5 你既然是从 kafka 取数据的,为什么会控制不好时间区间呢? Kafka 里面的消息都有 timestamp 的啊
    binjjam
        11
    binjjam  
    OP
       2017-05-29 21:09:45 +08:00
    @billlee kafka 实时被 druid.io 消费了哇...原始数据流只有一份,
    00:05 统计 00:00:00~00:04:59 的数据,
    00:10 统计 00:00:00~00:09:59 的数据,
    ...
    第二天 00:00 统计前一天 00:00:00~23:59:59 的数据
    关于   ·   帮助文档   ·   博客   ·   API   ·   FAQ   ·   实用小工具   ·   3159 人在线   最高记录 6679   ·     Select Language
    创意工作者们的社区
    World is powered by solitude
    VERSION: 3.9.8.5 · 24ms · UTC 13:37 · PVG 21:37 · LAX 05:37 · JFK 08:37
    Developed with CodeLauncher
    ♥ Do have faith in what you're doing.