Table Store(OTS) Writer

更新时间:2020-06-17 17:37:14

本页目录

  • 参数说明
  • 向导开发介绍
  • 脚本开发介绍

本文为您介绍Table Store(OTS) Writer支持的数据类型、写入方式、字段映射和数据源等参数及配置示例。

表格存储(Table Store)是构建在阿里云飞天分布式系统之上的NoSQL数据库服务,提供海量结构化数据的存储和实时访问。Table Store以实例和表的形式组织数据,通过数据分片和负载均衡技术,实现规模上的无缝扩展。

Table Store Writer通过Table Store官方Java SDK连接到Table Store服务端,并通过SDK写入Table Store服务端 。Table Store Writer本身对于写入过程进行诸多优化,包括写入超时重试、异常写入重试、批量提交等功能。

目前Table Store Writer支持所有Table Store类型,其针对Table Store类型的转换列表,如下所示。

类型分类 Table Store数据类型
整数类 INTEGER
浮点类 DOUBLE
字符串类 STRING
布尔类 BOOLEAN
二进制类 BINARY

说明 您需要将INTEGER类型的数据,在脚本模式中配置为INT类型,DataWorks会将其转换为INTEGER类型。如果您直接配置为INTEGER类型,日志将会报错,导致任务无法顺利完成。

参数说明

参数 描述 是否必选 默认值
datasource 数据源名称,脚本模式支持添加数据源,该配置项填写的内容必须与添加的数据源名称保持一致。
endPoint Table Store Server的服务地址。
accessId Table Store的AccessKey ID。
accessKey Table Store的AccessKey Secret。
instanceName Table Store的实例名称。

实例是您使用和管理Table Store服务的实体。开通Table Store服务后,需要通过管理控制台创建实例后,在实例内进行表的创建和管理。实例是Table Store资源管理的基础单元,Table Store对应用程序的访问控制和资源计量都在实例级别完成。

table 所选取的需要抽取的表名称,此处能且只能填写一张表。在Table Store中不存在多表同步的需求。
primaryKey Table Store的主键信息,使用JSON的数组描述字段信息。Table Store本身是NoSQL系统,在Table Store Writer导入数据过程中,必须指定相应的字段名称。

说明 Table Store的PrimaryKey仅支持STRING和INT两种类型,因此Table Store Writer本身也限定填写上述两种类型。

数据同步系统本身支持类型转换的,因此对于源头数据非STRING/INT,Table Store Writer会进行数据类型转换。配置示例如下。

"primaryKey" : [{"name":"pk1", "type":"string"},{"name":"pk2", "type":"int"}],
column 所配置的表中需要同步的列名集合,使用JSON的数组描述字段信息。

使用格式为:

{"name":"col2", "type":"INT"},

其中的name指定写入的Table Store列名,type指定写入的类型。Table Store类型支持STRING、INT、DOUBLE、BOOL和BINARY类型。

writeMode writeMode表示数据写入表格存储的格式,目前支持以下两种模式:

  • PutRow:对应于Table Store PutRow API,插入数据到指定的行。如果该行不存在,则新增一行。如果该行存在,则覆盖原有行。
  • UpdateRow:对应于Table Store UpdateRow API,更新指定行的数据。如果该行不存在,则新增一行。如果该行存在,则根据请求的内容在这一行中新增、修改或者删除指定列的值。
requestTotalSizeLimitation 该配置限制写入Table Store时单行数据的大小,配置类型为数字。 1MB
attributeColumnSizeLimitation 该配置限制写入Table Store时单个属性列的大小,配置类型为数字。 2MB
primaryKeyColumnSizeLimitation 该配置限制写入Table Store时单个主键列的大小,配置类型为数字。 1KB
attributeColumnMaxCount 该配置限制写入Table Store时属性列的个数,配置类型为数字。 1,024

向导开发介绍

暂不支持向导模式开发。

脚本开发介绍

配置一个写入Table Store作业,使用脚本模式开发的详情请参见通过脚本模式配置任务。

{"type":"job","version":"2.0",//版本号。"steps":[{ "stepType":"stream","parameter":{},"name":"Reader","category":"reader"},{"stepType":"ots",//插件名。"parameter":{"datasource":"",//数据源。"column":[//字段。{"name":"columnName1",//字段名。"type":"INT"//数据类型。},{"name":"columnName2","type":"STRING"},{"name":"columnName3","type":"DOUBLE"},{"name":"columnName4","type":"BOOL"},{"name":"columnName5","type":"BINARY"}],"writeMode":"",//写入模式。"table":"",//表名。"primaryKey":[//Table Store的主键信息。{"name":"pk1","type":"STRING"},{"name":"pk2","type":"INT"}]},"name":"Writer","category":"writer"}],"setting":{"errorLimit":{"record":"0"//错误记录数。},"speed":{"throttle":false,//false代表不限流,下面的限流速度不生效;true代表限流。"concurrent":1//作业并发数。}},"order":{"hops":[{"from":"Reader","to":"Writer"}]}
}

上一篇:OpenSearch Writer

下一篇:RDBMS Writer

相关文档

  • Table Store(OTS) Reader
  • 配置OTS数据源
  • OTSReader-Internal
  • OTSStream Reader
  • 通过脚本模式配置任务
  • TableStore(OTS)

相关产品

  • DataWorks

    新一代智慧大数据研发平台DataWorks(数据工场,原大数据开发套件)是从工作室、车间到工具集都齐备的一站式大数据工场,助力您快速完成数据集成、开发、治理、服务、质量、安全等全套数据研发工作。DataWorks + MaxCompute 在2018年获得著名分析评测机构Forrester的Cloud Data Warehouse云数据仓库世界排名第二的成绩,是唯一入选的中国产品。 DataWorks V2.0 在DataWorks V1.0的基础上新增业务流程、组件的概念,完善数据研发体系,支持双项目开发,隔离开发和生产,保证数据研发规范,减少错误代码。

  • MaxCompute

    大数据计算服务(MaxCompute,原名ODPS)是一种快速、完全托管的TB/PB级数据仓库解决方案。MaxCompute向用户提供了完善的数据导入方案以及多种经典的分布式计算模型,能够更快速的解决用户海量数据计算问题,有效降低企业成本,并保障数据安全。 诚邀您参加阿里云MaxCompute问卷调研,问卷填写大概需要花费您5-10分钟。我们将在认真填写的用户中随机抽取100名,每名用户赠送100元MaxCompute无门槛代金券。参与地址:https://survey.aliyun.com/apps/zhiliao/boGZtw_74

  • 智能数据构建与管理 Dataphin

    Dataphin(智能数据构建与管理)是智能的

阿里云:Table Store(OTS) Writer相关推荐

  1. 如何在阿里云上使用Data Lake Analytics分析Table Store数据

    0. Data Lake Analytics(简称DLA)介绍 数据湖(Data Lake)是时下热门的概念,更多阅读可以参考: https://en.wikipedia.org/wiki/Data_ ...

  2. 阿里云的NoSQL存储服务OTS的应用分析

    这篇文章主要介绍了阿里云的NoSQL存储服务OTS的应用分析,OTS作为阿里巴巴开发的NoSQL存储技术服务现已面向用户商业化,需要的朋友可以参考下. 1. 概要   OTS是构建在阿里云飞天分布式系 ...

  3. 百度网盘回应在 APP Store 下架;阿里云发布 AI 助手「通义听悟」;SQL:2023 正式发布|极客头条

    「极客头条」-- 技术人员的新闻圈! CSDN 的读者朋友们早上好哇,「极客头条」来啦,快来看今天都有哪些值得我们技术人关注的重要新闻吧. 整理 | 梦依丹 出品 | CSDN(ID:CSDNnews ...

  4. 阿里云推荐引擎使用教程

    2019独角兽企业重金招聘Python工程师标准>>> 产品概述: 推荐引擎(Recommendation Engine,以下简称RecEng,特指阿里云推荐引擎)是在阿里云计算环境 ...

  5. Table Store: 海量结构化数据实时备份实战

    Table Store: 海量结构化数据实时备份实战 数据备份简介 在信息技术与数据管理领域,备份是指将文件系统或数据库系统中的数据加以复制,一旦发生灾难或者错误操作时,得以方便而及时地恢复系统的有效 ...

  6. 阿里云产品头条(2017年12月刊)

    摘要: 一.新产品发布1.云防火墙 商业化 发布云防火墙是一款云环境下的防火墙产品,首创了基于业务可视的结果,实现业务梳理和业务隔离的技术.适用于互联网/通用/游戏/金融/新零售/专用云等行业客户.产 ...

  7. 如何利用阿里云进行创建属于自己的网站

    阿里云:现在国内最大的云商,成立早,产品线很丰厚,优惠力度广. 腾讯云:推行阶段,优惠仍是蛮多的,功用嘛,我没用过,问了一些人他们说不咋滴. 景安云:很廉价,可是不安稳,主张他们做活动购买,五折!可是 ...

  8. 个人建设网站流程解说,手把手教你如何在阿里云上搭建自己的网站

    现如今信息化时代,很多企业甚至是个人都有自己搭建网站的需求,目前建站有两方式,第一:找网络公司全程负责搭建:第二:自己建设:找网络公司建设网站市场价格不一,网络公司的实力技术也不一样,所以会有很多的建 ...

  9. 阿里云实战之一(必备程序安装)

    为了放我的在线代码编辑器,我用了阿里云的空间,用的linux服务器,空间性能见探针http://www.wcodei.com/i.php 1.安装远程操作工具 下载putty.exe,输入公网ip,端 ...

最新文章

  1. STM32 电机教程 5 - 步进电机基础知识介绍
  2. Codeforces 1110 简要题解
  3. IPv6终于要取代IPv4了!阿里云将全面提供IPv6服务
  4. centos7开启tcp6_centos中docker映射出来的端口被tcp6监听,而没有被tcp监听导致ip+端口无法进行访问...
  5. c# image转换为bitmap,C# - 转换WPF Image.source到System.Drawing.Bitmap
  6. spring学习--基于注解 注入属性
  7. python学习(八)----外星人入侵(项目篇)
  8. 高中数学 经典题选 排列 组合 概率
  9. 完全卸载exchange2010
  10. 关于GEOS库配置与安装
  11. 不知道如何写好作文?写好作文的十大技巧赶紧收好
  12. sqlserver之远程访问配置
  13. TCTF writeup
  14. ROS双臂定点抓取问题记录
  15. 北京东方国信??有谁去过啊。。公司怎么样?
  16. 易贝按关键字搜索EBAY商品 API 返回值说明
  17. OS101:图灵机、通用图灵机与bootsect
  18. sql练习学生成绩查询实践
  19. 英文版 耶稣爱我 Jesus Loves me 童声
  20. 使用盗版软件开发工具面临的若干法律问题

热门文章

  1. python连接数据库步骤_Python连接mysql数据库
  2. java socket client_java socket client
  3. 为什么从网页上打印怎们好像被缩放_便捷高效低成本,映美热敏云打印机CTP-180UWE体验...
  4. QT每日一练day11:QMainWindow
  5. python堆排序的库_Python:堆排序
  6. mysql insert s锁_MySQL 死锁套路:唯一索引 S 锁与 X 锁的爱恨情仇
  7. 大学计算机思维导图_【21计算机考研】改考408+1!上海电力大学翻倍扩招,仍考数据结构!...
  8. oracle查看本机字符集,查看、修改oracle字符集,查看oracle版本
  9. python多分类画roc曲线_利用python制作ROC曲线进行多分类
  10. 成员变量隐藏c语言,C语言中隐藏结构体的细节