全部产品
弹性计算 会员服务 网络 安全 移动云 数加·大数据分析及展现 数加·大数据应用 管理与监控 云通信 阿里云办公 培训与认证 智能硬件
存储与CDN 数据库 域名与网站(万网) 应用服务 数加·人工智能 数加·大数据基础服务 互联网中间件 视频服务 开发者工具 解决方案 物联网 更多
流计算

创建分析型数据库(AnalyticDB)

更新时间:2018-05-15 13:43:25

分析型数据库(AnalyticDB)

分析型数据库(AnalyticDB),是阿里巴巴自主研发的海量数据实时高并发在线分析(Realtime OLAP)云计算服务,使得您可以在毫秒级针对千亿级数据进行即时的多维分析透视和业务探索。分析型数据库对海量数据的自由计算和极速响应能力,能让用户在瞬息之间进行灵活的数据探索,快速发现数据价值,并可直接嵌入业务系统为终端客户提供分析服务。

DDL定义

流计算支持使用RDS作为结果输出。示例代码如下:

  1. CREATE TABLE stream_test_hotline_agent (
  2. id INTEGER,
  3. len BIGINT,
  4. content varchar
  5. primary key(id)
  6. ) WITH (
  7. type='ads',
  8. url='jdbc:mysql:/XXXXXXX/ads_test',
  9. tableName='blink_test',
  10. userName='DXP_6XXXXXXXyun.com',
  11. password='1XXXXXX4',
  12. batchSize='500'
  13. );

WITH参数

参数 注释说明 备注
url jdbc连接地址 ADS详情地址 ,例如:(jdbc:mysql://mydbname-xxxx.ads-hz.aliyuncs.com:5544/my_ads_db)
tableName 表名
username 账号
password 密码
maxRetryTimes 写入重试次数 可选,默认为10
bufferSize 去重的buffer大小 可选,默认为5000,表示输入的数据达到5000条就开始输出
batchSize 每次写的批次大小 可选,默认为1000
batchWriteTimeoutMs 写超时时间 可选,单位毫秒,默认值5000,表示数据超过了5秒,还没有往ots写过,就会将缓存的数据都写一次
connectionMaxActive 单连接池最大连接数 可选,默认值30
ignoreDelete 是否忽略delete操作 默认为false
  • 写入如果是20015错误的话,是因为batchSize设置的过大 ads单次batch不能超过1M 也就是如果batchSize设置1000的话,平均每条记录大小不能超过1Kb,可以根据这个限制来合理的设置batchSize数目

类型映射

ADS和流计算字段类型对应关系,强烈建议用户使用该对应关系进行DDL声明:

ADS字段类型 流计算字段类型
boolean boolean
tinyint int
smallint int
int int
bigint bigint
double double
varchar varchar
date date
本文导读目录