利用streamsets实现MongoDB到Oracle的实时同步

相同操作不再重述,请翻看前面几篇博文

因mongodb自带_id字段,所以oracle建表需要对应建一个ID字段。
利用streamsets实现MongoDB到Oracle的实时同步
利用streamsets实现MongoDB到Oracle的实时同步

前提:mongoDB开启oplog,且版本在3.6以上
示例:https://www.jianshu.com/p/4ba61033775e
本例需要以下组件
利用streamsets实现MongoDB到Oracle的实时同步

MongoDB组件按下图配置
利用streamsets实现MongoDB到Oracle的实时同步
利用streamsets实现MongoDB到Oracle的实时同步

输入账号密码
利用streamsets实现MongoDB到Oracle的实时同步

Stream select table按下图配置
${record:value(’/ns’)==‘streamsets.stream_test’}
利用streamsets实现MongoDB到Oracle的实时同步

Stream select dml按下图配置
${record:value(’/op’)‘i’}
${record:value(’/op’)
‘u’}
${record:value(’/op’)==‘d’}
利用streamsets实现MongoDB到Oracle的实时同步

Jdbc producer 配置如下图所示
利用streamsets实现MongoDB到Oracle的实时同步
利用streamsets实现MongoDB到Oracle的实时同步
利用streamsets实现MongoDB到Oracle的实时同步

输入账号密码
利用streamsets实现MongoDB到Oracle的实时同步

配置完即可启动进行测试