全部产品
存储与CDN 数据库 安全 应用服务 数加·人工智能 数加·大数据基础服务 互联网中间件 视频服务 开发者工具 解决方案 物联网 钉钉智能硬件
流计算

创建云数据库(RDS)结果表

更新时间:2018-01-04 14:39:59

什么是云数据库(RDS)

云数据库RDS(ApsaraDB for RDS,简称RDS)是一种稳定可靠、可弹性伸缩的在线数据库服务。基于飞天分布式系统和全SSD盘高性能存储,支持MySQL、SQL Server、PostgreSQL和PPAS(高度兼容Oracle)引擎。目前流计算支持的RDS引擎包括: MySQL。

DDL定义

流计算支持使用RDS作为结果输出,目前支持数据存储类型有MySql。示例代码如下:

  1. create table rds_output(
  2. id int,
  3. len int,
  4. content VARCHAR,
  5. primary key(id,len)
  6. ) with (
  7. type='rds',
  8. url='jdbc:mysql:XXXXXXXXXX',
  9. tableName='test4',
  10. userName='test',
  11. password='XXXXXX'
  12. );

需要注意的是:

  • 流计算写入RDS数据库结果表原理是,针对流计算每行结果数据,拼接成一行SQL向目标端数据库进行执行。如果使用批量写,需要在url后面加上 ?rewriteBatchedStatements=true,否则性能会很差。

  • RDS/Mysql支持自增主键,如果需要让流计算写入数据支持自增主键,在DDL中不声明该自增字段即可。例如,ID是自增字段,那么流计算DDL不写出该自增字段,那么数据库在一行数据写入过程中数据库会自动填补相关的自增字段。

Mysql DDL

  1. create table rds_output(
  2. content VARCHAR,
  3. content VARCHAR,
  4. primary key(id)
  5. ) with (
  6. type='rds',
  7. url='jdbc:mysql:XXXXXXXXXX',
  8. tableName='test4',
  9. userName='test',
  10. password='XXXXXX'
  11. );

WITH参数

参数 注释说明 备注
url 地址 RDS的URL地址
tableName 表名
userName 用户名
password 密码
maxRetryTimes 最大尝试插入次数 可选,默认为3
batchSize 每次写的批次大小 可选,默认值50,表示每次写多少条
bufferSize 去重的buffer大小,需要指定主键才生效 可选,默认值1(1.4.1默认值改为1000),表示输入的数据达到1条就开始输出
flushIntervalMs 写超时时间 可选,单位毫秒,默认值5000,表示数据超过了5秒,还没有写过,就会将缓存的数据都写一次
excludeUpdateColumns 对相同key的值更新时排除掉相应的column 可选,默认为空(primary keys 字段默认会排除)
ignoreDelete 是否忽略delete操作 默认为false
本文导读目录