NIFI1.21.0通过Postgresql11的CDC逻辑复制槽实现_指定表多表增量同步_增加修改实时同步_使用JsonPath及自定义Python脚本_03---大数据之Nifi工作笔记0055
本文共 248 字，大约阅读时间需要 1 分钟。
然后接着上节再来看插入:
可以看到我们要使用ReplaceText处理器,拼接insert语句的话,要知道一下内容:
table表名 columnnames 列名集合 columnnames列值集合
所以这里我们来写一下:
首先配置insert对应的EvaluateJsonPath处理器,设置对应的,
{"xid":571,"change":[{"kind":"insert","schema":"public","table":"userinfo","columnnames":["id",& 转载地址：http://ifjfk.baihongyu.com/
你可能感兴趣的文章
Netty原理分析及实战（一）-同步阻塞模型（BIO）
查看>>
Netty原理分析及实战（三）-高可用服务端搭建
查看>>
Netty原理分析及实战（四）-客户端与服务端双向通信
查看>>
Netty发送JSON格式字符串数据
查看>>
Netty和Tomcat的区别已经性能对比
查看>>
Netty基础—1.网络编程基础二
查看>>
Netty基础—3.基础网络协议二
查看>>
Netty基础—7.Netty实现消息推送服务一
查看>>
Netty基础—8.Netty实现私有协议栈二
查看>>
Netty多线程 和 Redis6 多线程对比
查看>>
Netty学习总结（2）——Netty的高性能架构之道
查看>>
Netty学习总结（3）——Netty百万级推送服务
查看>>
Netty学习总结（5）——Netty之TCP粘包/拆包问题的解决之道
查看>>
Netty学习总结（6）——Netty使用注意事项
查看>>
Netty客户端断线重连实现及问题思考
查看>>
Netty工作笔记0001---Netty介绍
查看>>
Netty工作笔记0003---IO模型-BIO-Java原生IO
查看>>
Netty工作笔记0006---NIO的Buffer说明
查看>>
Netty工作笔记0007---NIO的三大核心组件关系
查看>>
Netty工作笔记0008---NIO的Buffer的机制及子类
查看>>