当前位置:网站首页>TDengine可通过数据同步工具 DataX读写
TDengine可通过数据同步工具 DataX读写
2022-07-05 09:28:00 【涛思数据(TDengine)】
小 T 导读:DataX 是由阿里云开源的离线数据同步工具/平台,目前已经支持多种主流异构数据源在内的高效的数据互相同步功能。我们的研发团队完成了 TDengine 的适配,相关代码已被 DataX 官方接受并合并到主干中。
DataX 是由阿里云开源的离线数据同步工具/平台,目前已经实现了包括 MySQL、Oracle、OceanBase、SQL Server、PostgreSQL、HDFS、Hive、HBase 等多种异构数据源在内的高效的数据互相同步功能。
DataX 的设计思路是:
DataX 本身作为数据同步框架,将不同数据源的同步抽象为从数据源读取数据的
Reader插件,以及向目标端写入数据的Writer插件,理论上 DataX 框架可以支持任意数据源类型的数据同步工作。同时 DataX 插件体系作为一套生态系统,每接入一套新数据源,就可以实现该数据源和现有数据源的互通。
基于该设计思路,我们的研发团队完成了 TDengine 的适配,实现了 TDengineReader 和 TDengineWriter 两个插件,并被 DataX 官方接受,合并到了其主干中。
TDengineReader 提供的功能包括:
- 支持通过 SQL 进行数据筛选;
- 根据时间间隔进行任务切分;
- 支持 TDengine 的全部数据类型;
- 支持批量读取,可以通过
batchSize参数控制批量拉取结果集的大小,从而提高读取性能。
TDengineWriter 支持的功能包括:
- 支持 OpenTSDB 的 json 格式的行协议,可以使用 TDengine 的 Schemaless 方式写入 TDengine。
- 支持批量写入,可以通过
batchSize参数控制批量写入的数量,从而提高写入性能。
目前 TDengine 已经加入 DataX 正式支持的数据库列表中。

现在,如果用户要将历史 Database(比如 MySQL、OpenTSDB 等)中的数据迁移到 TDengine,或者将 TDengine 中的数据导出,就可以利用 DataX 来实现了。
更多使用细节,可以参考“基于 DataX 的 TDengine 数据迁移工具”一文。
基于 DataX 的 TDengineWriter 和 TDengineReader 的实现和最新动态,请关注:https://github.com/taosdata/DataX
想了解更多 TDengine Database的具体细节,欢迎大家在GitHub上查看相关源代码。
边栏推荐
- Why does everyone want to do e-commerce? How much do you know about the advantages of online shopping malls?
- Composition of applet code
- Node の MongoDB Driver
- 22-07-04 西安 尚好房-项目经验总结(01)
- SQL learning alter add new field
- NIPS2021 | 超越GraphCL,GNN+对比学习的节点分类新SOTA
- My life
- [object array A and object array B take out different elements of ID and assign them to the new array]
- 百度评论中台的设计与探索
- [ctfhub] Title cookie:hello guest only admin can get flag. (cookie spoofing, authentication, forgery)
猜你喜欢
随机推荐
Nips2021 | new SOTA for node classification beyond graphcl, gnn+ comparative learning
My life
Kotlin introductory notes (VI) interface and function visibility modifiers
[two objects merged into one object]
MySQL does not take effect in sorting string types
OpenGL - Lighting
Lepton 无损压缩原理及性能分析
Community group buying has triggered heated discussion. How does this model work?
Wxml template syntax
Can't find the activitymainbinding class? The pit I stepped on when I just learned databinding
【阅读笔记】图对比学习 GNN+CL
LeetCode 503. 下一个更大元素 II
高性能Spark_transformation性能
LeetCode 31. 下一个排列
Kotlin introductory notes (VII) data class and singleton class
图神经网络+对比学习,下一步去哪?
微信小程序获取住户地区信息
[object array A and object array B take out different elements of ID and assign them to the new array]
使用el-upload封装得组件怎么清空已上传附件
Kotlin introductory notes (VIII) collection and traversal
![一题多解,ASP.NET Core应用启动初始化的N种方案[上篇]](/img/c4/27ae0d259abc4e61286c1f4d90c06a.png)








