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

创建表格存储结果表(Table Store)

更新时间:2018-04-12 11:16:53

什么是表格存储(TableStore)

表格存储(Table Store)是构建在阿里云飞天分布式系统之上的分布式NoSQL数据存储服务,根据99.99%的高可用以及11个9的数据可靠性的标准设计。表格存储通过数据分片和负载均衡技术,实现数据规模与访问并发上的无缝扩展,提供海量结构化数据的存储和实时访问。

DDL定义

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

  1. CREATE TABLE stream_test_hotline_agent (
  2. name varchar,
  3. age BIGINT,
  4. birthday BIGINT,
  5. primary key(name,age)
  6. ) WITH (
  7. type='ots',
  8. instanceName='bliXXXXst',
  9. tableName='users2',
  10. accessId='LTXXXXXXz48ke',
  11. accessKey='prc1bXXXXXXX6oPZd9gidXDY',
  12. endPoint='http://XXXXXXXXou.ots.aliyuncs.com',
  13. valueColumns='biXXXXay'
  14. );

注意

推荐使用数据存储功能:表格存储.

valueColumns的值不能是声明的主键,可以是主键之外的任意字段。

WITH参数

参数 注释说明 备注
instanceName 实例名
tableName 表名
endPoint 实例访问地址 OTS的endpoint地址
accessId 访问的id
accessKey 访问的键
valueColumns 指定插入的字段列名,多个以逗号分割 例如:’ID,NAME’
bufferSize 去重的buffer大小 可选,默认值5000,表示输入的数据达到5000条就开始输出
batchWriteTimeoutMs 写超时时间 可选,单位毫秒,默认值5000,表示数据超过了5秒,还没有往ots写过,就会将缓存的数据都写一次
batchSize 每次写的批次大小 可选,默认值100
retryIntervalMs 重试间隔时间 可选,单位毫秒,默认值1000
maxRetryTimes 最大重试次数 可选,默认值100
ignoreDelete 是否忽略delete操作 默认为false

类型映射

OTS字段类型 流计算字段类型
integer bigint
string varchar
boolean boolean
double double

注意:

  • TableStore结果表须定义有PrimaryKey,输出数据以Update方式追加到现有TableStore表
本文导读目录