Apache Druid是一个分布式内存实时分析系统,用于解决如何在大规模数据集下快速的、交互式的查询和分析问题。
基本特点
Apache Druid具有如下特点:
支持亚秒级的交互式查询。例如,多维过滤、Ad-hoc的属性分组和快速聚合数据。
支持实时的数据消费。
支持多租户同时在线查询。
支持PB级数据、千亿级事件快速处理,支持每秒数千查询并发。
支持高可用,并且滚动升级。
应用场景
实时数据分析是Apache Druid最典型的使用场景。该场景涵盖的面很广,例如:
实时指标监控
推荐模型
广告平台
搜索模型
Apache Druid架构
Apache Druid拥有优秀的架构设计,多个组件协同工作,共同完成数据从摄取到索引、存储和查询等一系列流程。
Druid工作层(数据索引以及查询)包含以下组件:
Realtime组件负责数据的实时摄入。
Broker组件负责查询任务的分发以及查询结果的汇总,并将结果返回给用户。
Historical组件负责索引后的历史数据的存储,数据存储在deep storage。Deep storage可以是本地,也可以是HDFS等分布式文件系统。
Indexing service包含以下两个组件:
Overlord组件负责索引任务的管理、分发。
MiddleManager负责索引任务的具体执行。
Druid segments(Druid索引文件)管理层涉及以下组件:
Zookeeper:负责存储集群的状态以及作为服务发现组件。例如集群的拓扑信息、overlord leader的选举、indexing task的管理等。
Coordinator:负责segments的管理。例如segments下载、删除以及如何在historical之间做均衡等。
Metadata storage:负责存储segments的元信息,以及管理集群各种各样的持久化或临时性数据。例如配置信息、审计信息等。
E-MapReduce增强型Druid
E-MapReduce Druid基于Apache Druid做了大量的改进,包括与E-MapReduce和阿里云周边生态的集成、方便的监控与运维支持、易用的产品接口等,实现即买即用和7*24免运维。
E-MapReduce Druid目前支持的特性如下所示:
支持以OSS作为deep storage。
支持将OSS文件作为批量索引的数据来源。
支持从日志服务(Log Service)流式地索引数据(类似于Kafka),并提供高可靠保证和exactly-once语义。
支持将元数据存储到RDS。
集成了Superset工具。
方便地扩容和缩容(缩容针对Task节点)。
丰富的监控指标和告警规则。
故障迁移。
具有高安全性。
支持HA。