AI 助理
备案控制台
开发者社区 大数据与机器学习 正文

大佬有知道 Flink CDC怎么接入tdsql-postgresql 么 也就是tbase？

大佬有知道 Flink CDC怎么接入tdsql-postgresql 么 也就是tbase？image.png

展开
收起
真的很搞笑 2023-06-04 18:49:27 210 分享 版权

版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

1 条回答
写回答
取消 提交回答
  • 1941623231718325
    • Flink CDC可以接入tdsql-postgresql，实现从tdsql-postgresql中实时读取数据变化，并将其转换为Flink表或流。具体的步骤如下：
      • 在tdsql-postgresql中开启逻辑复制功能，以便生成wal2json格式的二进制日志。
      • 在Flink中创建一个PostgreSQL CDC连接器，指定tdsql-postgresql的连接信息、数据库名、表名、用户名、密码等参数。
      • 在Flink中使用SQL或Table API对PostgreSQL CDC连接器进行操作，比如查询、过滤、转换、输出等。
    2023-10-13 10:59:26
    赞同 1 展开评论
问答分类：
流计算 云原生数据库 PolarDB 实时计算 Flink版
问答标签：
实时计算 Flink版CDC flink PostgreSQL 实时计算 Flink版postgresql cdc PostgreSQL 实时计算 Flink版cdc postgresql
问答地址：
开发者社区 > 大数据与机器学习 > 问答
相关问答
怎么将postgresql中数据 通过 flink-cdc的方式推送到postgresql中？
141
1
0
Flink CDC里请问下支持pgsql内核是TBase吗？
96
0
0
flinkcdc 中postgresql cdc，没从检查点重启，记录继续增量消费变更数据吗？
96
1
0
postgresql 只有部分字段权限Flink CDC 这个怎么同步呀？
66
0
0
flink-cdc读取 postgresql，从savepoint重启后一直报这个错误，为什么?
82
1
0
Flink支持postgresql整库同步到adb吗？
93
1
0
flink读写postgresql，任务状态为r时应该如何处理
78
0
0
用flink cdc去读取rds postgresql的日志突然就跑不通了，怎么回事？
90
3
0
Flink cdc同步postgresql的分区表支持？
150
1
0
Flink CDC里我现在想postgresql 能实时入库 hive，并且能实现断点续传，怎么办？
156
2
0

大数据与机器学习

大数据领域前沿技术分享与交流，这里不止有技术干货、学习心得、企业实践、社区活动，还有未来。

我要提问

相关文章

  • 淘宝闪购基于Flink&Paimon的Lakehouse生产实践：从实时数仓到湖仓一体化的演进之路
  • 除了Foldables.js库，还有哪些库可以实现折叠屏适配？
  • 【顶级EI复现】基于电力系统碳排放流理论的碳排放分摊模型研究（Matlab代码实现）
  • 基于实时迭代的数值鲁棒NMPC双模稳定预测模型（Matlab代码实现）
  • 基于模型预测控制对PMSM进行FOC控制，模拟控制了PMSM的速度（Simulink仿真实现）

    • 热门讨论

    热门文章

  • Flink CDC任务从savepoint/checkpoints状态中恢复作业错误问题
  • 数据来源：com.alibaba.fastjson.JSONException: syntax er
  • 虚拟机占用内存特别大，90多个G,网上各种方法都试过了，怎么解决这个问题
  • 请问如何用flink sql客户端用yarn application模式提交任务呢？
  • 阿里云服务器无法安装docker
  • 阿里云磁盘大小是多少？
  • flink的1cu是指1cpu还是1cpu+4g存储？
  • 阿里云和腾讯云服务器哪个好！
  • 请问下大家有没有遇到过这个错:Caused by: java.lang.ClassNotFoundE
  • FlinkCDC MySQL 中 scan.startup.mode 用的是什么模式啊？
    • 展开全部
  • DataV首次实战分享：教你30分钟创建汽车大屏
  • 阿里封神谈hadoop生态学习之路
  • 你刚吃的兰州牛肉面，背后就藏着大数据
  • odps是什么?
  • ajax请求总是不成功？浏览器的同源策略和跨域问题详解
  • 【玩转数据系列二】机器学习应用没那么难，这次教你玩心脏病预测
  • 【技术实验】mysql准实时同步数据到Elasticsearch
  • 阿里云MaxCompute（大数据）公开数据集---带你玩转人工智能
  • 吴刚专访--大数据和 MaxCompute 技术和故事
  • 2017杭州云栖大会FAQ（持续更新中）
    • 展开全部
    还有其他疑问?
    咨询AI助理