postgresql在腾讯数据库_PostgreSQL在腾讯数据仓库TDW的使用教程

更新时间:2020-03-07    来源:PostgreSQL    手机版     字体:

【www.bbyears.com--PostgreSQL】

TDW作为一个离线数据分析系统,在处理海量数据方面,通过并行计算,有很好的性能优势。但是腾讯知道,想用一个大而全的系统解决所有问题一般也是不现实的,同样,TDW也有它的劣势,比如对小数据处理性能低,update/delete性能差、接口不丰富等。因此腾讯引入一个强大的开源数据库PostgreSQL,并对其做一些功能扩展,使之有访问TDW数据的能力;同时腾讯在TDW中开发了一种新的存储引擎,腾讯称之为pgdata存储引擎,使得TDW具备读写PostgreSQL中的数据的能力。

 

tdw

 

PostgreSQL在腾讯应用概述

 


主要业务场景为OLAP数据分析

大部分为内部系统,少量应用于对外服务
作为TDW系统的补充而存在
主要应用形式为业务使用TDW提供的tPG服务

TDW团队负责机器、运营和技术支持
业务提交申请即可使用
PG与MySQL
MySQL可以支撑,则优先使用MySQL
MySQL不能满足,再考虑使用PG

 

TDW与PostgreSQL互访问功能的实现,对TDW是一个强有力的补充,这些主要体现在如下3点:

 


弥补TDW接口不丰富的短板。TDW缺乏标准化的JDBC/ODBC,编程接口也不丰富,而PostgreSQL有社区强大的力量,提供了JDBC/ODBC, shell, C/C++, C#, python, perl等各种语言的接口,用户通过这些丰富的接口和腾讯开发的PostgreSQL的TDW桥接工具tdwlink,访问TDW中的数据。
弥补TDW小数据分析效率底的短板。TDW在海量数据处理时,可以发挥它并行执行的优势。但是对于小数据分析,它的性能反而不如传统的DB。使用PostgreSQL,对于10GB以内的数据分析,可以获得更好的性能和时间响应,一般可以在秒级返回结果,相比TDW分钟级的响应,tPG在这种场景下更有优势。
作为TDW的pgdata存储引擎,弥补TDW update/delete效率底下的短板。TDW作为数据仓库系统,对于记录级的update/delete支持不是很好。在TDW中记录级的update/delete,会导致整个表的重写,也就是说,即使delete一条数据,也会导致整个表重写一遍,耗费大量系统资源。而tPG作为传统数据库,记录级的update和delete效率非常高。

 

tPG的作用

 


TDW数据集市,结果展示
对外提供JDBC/ODBC等标准化接口
提高高校的小数据分析功能
提高高校的update/delete功能

 

TDW为什么要引入tPG

 

TDW应用推广遇到的挑战

 


TDW离线分析,不能满足业务的结果库需求
TDW没有标准的JDBC、ODBC接口,难以与商业工具对接
TDW处理小数据、做update和delete效率低

 

解决方案

 



TDW不是万能的,不可能满足所有应用场景
需要建设一套RDBMS,作为TDW的补充

要方便用户迁移已有业务,做好有工具做迁移
要有标准的JDBC、ODBC接口
性能要好
功能容易扩展

 

为什么选择PostgreSQL

 


完善的DB功能

SQL标准支持较好
支持PL/pgSQL等多种过程语言
支持视图、分析函数、CTE等高级特性
OLAP性能超过MySQL

复杂SQL性能高10倍+
基于cost的SQL优化,调优手段更多
部分索引,函数索引,cluster索引
插件式的功能扩展

已有访问Mysql、Redis、文本等外部数据源插件
很容易开发访问TDW的插件
TB级数据库备份与恢复(基于zfs快照技术)

速度快,对上TB的数据做快照耗时小于1秒
占用空间小,新生成的快照几乎不占空间
支持快照增量备份,支持快速rollback

 

PostgreSQL系统在TDW生态圈中的位置如下图所示,tPG是腾讯对扩充之后的PostgreSQL的一个叫法:

 

tpg

 

下面分两个部分对TDW与PostgreSQL的互访问功能做一个介绍,也即是pgdata存储引擎以及tdwlink功能。

 

pgdata存储引擎

 

TDW本身支持多种存储格式,包括textfile,rcfile,pbfile,在这个基础上,腾讯开发一种新的存储引擎,也即pgdata存储引擎,能够透明的存储以及访问PostgreSQL中的数据,具体情况如下图:

 

pgdata

 

在使用上,只需要在创建表的时候指定为pgdata存储引擎即可,例如使用如下语句就可以创建此类型的外表

 


 







1


create external table foo(idx bigint, str string) stored as pgdata

 

在后续访问过程中就和使用其他TDW表一般即可,在此简单说明一下访问的实现方式,访问的数据流大致如下

 

pgdata-flow

 


    在解析SQL查询语句时,先分解出每个子查询,然后对每个子查询总是会首先判断当前查询涉及的表中是pgdata外表,如果没有DB外表则走正常的查询语句执行流程;
    如果有pgdata外表, 接着再检查在本次查询中涉及到的外表数据是否已经导入,如果导入则直接复用已经导入的数据,如果没有则对相应的子查询进行加工,将其转换为相应的标准关系型数据库SQL语句,然后从表中获取连接信息,使用JDBC执行查询语句;
    将查询结果的数据从数据库中导入到位于tmp目录下的一个随机HDFS目录中,这个随机目录使用UUID生成,因此可以保证唯一性,而不与其他查询语句产生冲突,然后将其设置为外表的数据所在的HDFS文件路径,Mapreduce任务会自动读取该路径作为任务的输入路径;
    在该条查询执行结束以后,并且查询结果已经获取成功,则清除掉这个临时文件。如果查询出现了异常也会自动的清理到已经导入的垃圾数据信息。

 

tdwlink功能

 

SQL标准中包含了一个名为SQL/MED也即”SQL Management of External Data”的功能, PostgreSQL在2011年的9.1版本使用一种叫Foreign Data Wrappers的机制对此标准做了只读支持,开发人员只需要对相应的数据源开发相应的插件即可通过PostgreSQL对远端数据源进行访问。目前社区已经有很多基于此功能开发的插件,诸如oracle_fdw,mysql_fdw,redis_fdw等,腾讯团队基于PostgreSQL的这个特性,开发了具备访问TDW数据能力的插件,称之为tdw_fdw,可以参考下图:

 

tdwlink

 

为了方便用户使用此功能,腾讯开发了一个存储过程tdwlink,用户只需要事先配置好对应的Foreign server以及认证信息,即可很方便的使用,例如腾讯已经定义好了tdw_svr这个server,想访问tdw里的test库的test表,只需要select tdw_meta.tdwlink(‘tdw_svr’,‘test’,‘select col1, col2 from test’)即可。由于此函数是通过PostgreSQL提供的,因此可以使用PostgreSQL提供的任意接口来使用,这样也间接的扩充了TDW所具备的访问接口。这里补充一点,腾讯的tdw_fdw插件是基于PostgreSQL 9.1版本开发的,这个版本的Foreign Data Wrappers只能对外部数据源提供只读访问,因此腾讯的tdw_fdw只能够提供对TDW的只读访问,而最新发布的PostgreSQL9.3版本的Foreign Data Wrappers已经提供写支持,这个也是腾讯的tdw_fdw插件后续可以进行功能扩充的地方。

 

tPG使用的开源插件

 


分区管理:基于pg_partman进行改造
监控:check_postgres和pgBadger
缓存预热:pgfincore
实例间互相访问:dblink
读取MySQL数据:mysql_fdw
中文全文检索:zhparser

 

tPG运营现状

 

目前运营情况

 


11套tPG实例,共约40台机器
已用存储约30TB,最大实例存储达5TB
tPG在公司内的用总户数100人+
没有因PG本身出过事故,用户评价积极

 

业务类型

 


对外:用户报表
对内:TDW系统,30多个业务的报表系统、数据提取系统、BI系统、营销系统等

 

tPG应用未来规划

 


为业务提供集群版PG-XC服务
更丰富的应用场景

地理信息(PostGis )
机器学习与数据挖掘(Madlib )
R统计分析(PL/R )

接入流程自助化

将tPG服务云化,降低运维人工参与量

本文来源:http://www.bbyears.com/shujuku/85860.html

热门标签

更多>>

本类排行