码迷,mamicode.com
首页 > 其他好文 > 详细

淘宝平台进行数据的实时传输: TimeTunnel介绍

时间:2015-07-23 17:17:48      阅读:3210      评论:0      收藏:0      [点我收藏+]

标签:

在班级工作中遇到似业务场景中的实时流传输数据的访问,所以,淘宝实时数据仓库这个人做了一些研究和了解。

本文介绍的业务场景和淘宝的设计TimeTunnel工具,从淘宝数据仓库团队沟通过程中的图像文字sildes。也参考了一些相关文件。


业务背景

TimeTunnel(简称TT)是一个基于thrift通讯框架搭建的实时传输数据平台,具有高性能、实时性、顺序性、高可靠性、高可用性、可扩展性等特点(基于Hbase)。

眼下TimeTunnel在阿里巴巴广泛的应用于日志收集、数据监控、广告反馈、量子统计、数据库同步等领域。


开源在:TaoCode,代码是开源的。

 

业务保障:

保证为全部的报表按时准备好所需数据,延迟不超过一分钟。

保证为全部的实时应用提供实时数据,延迟不超过一秒钟。

 

在整个数据仓库中的角色(图中”TT”字样):

技术分享

在全量/批量数据导入部分使用的是DHW和DataX。当中DataX貌似是开源的,也是一个不落地的异构数据源传输工具。

而在增量,或者说是流式场景下,这部分数据的採集和导入就依赖了TimeTunnel。


TT对接的Storm和Galaxy流计算模块也简单提一下:

galaxy是一套支持SQL定义业务逻辑的流计算服务化平台

galaxy之于storm,就类似hive之于hadoop的关系

下图为Galaxy的一个架构图:

技术分享


组件

技术分享

Time Tunnel大概有几部分组成。TTmanager,Client,Router。Zookeeper。Broker。

 

TTManager: 负责对外提供队列申请、删除、查询和集群的管理接?口;对内故障发现,发起队列迁移

 

Client是一组訪问timetunnel的api。主要有三部分组成:安全认证api。公布api,订阅api。眼下client支持java。python,php三种语言。

 

Router:为client提供路由信息,找到为消息队列提供服务的Broker。Router是訪问timetunnel的门户。主要负责路由、安全认证和负载均衡。Client訪问timetunnel的第一步是向Router进行安全认证,假设认证通过,Router依据Client要公布或者订阅的topic对Client进行路由,使Client和正确的Broker建立连接,路由的过程包括负载均衡策略,Router保证让全部的Broker平均地接收Client訪问。

 

Zookeeper是hadoop的开源项目,其主要功能是状态同步。Broker和Client的状态都存储在这里。

 

Broker是timetunnel的核心,负责消息的存储转发。承担实际的流量,进行消息队列的读写操作。

技术分享


其它

对接数据

  • 数据库的日志(如mysql、oracle等)
  • server产生的日志(如apache)
  • app通过接口产生的数据

技术分享

队列资源

  • 队列是一种资源,TimeTunnel提供队列。
  • 队列按需申请,订阅队列接口

持续服务

  • 故障发现。发起迁移
  • Broker之间流量均衡
  • 上下线机器平稳扩容

WhyHBase?

  • 顺序scan速度快
  • 非常好的扩展性
  • 强一致性
  • 高并发写
  • 底层数据存储基于HDFS
  • 开源,社区活跃
  • 国内顶级的运维和开发团队

HBase表设计

  • 一个Queue相应一个region
  • 一组Queue(256/512)相应一个表
  • Rowkey:queueID + timestamp + seq +brokerID
  • 数据列族+属性列族
  • 按天分表,方便删除历史数据
  • Pre-Sharding减少compact和split的发生


掌声 :)


版权声明:本文博客原创文章,博客,未经同意,不得转载。

淘宝平台进行数据的实时传输: TimeTunnel介绍

标签:

原文地址:http://www.cnblogs.com/gcczhongduan/p/4670782.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!