我正在使用传输器管道在源数据库 Mongo(版本 = 3.4)和 Sinc 数据库 Mongo(版本 = 4.4)之间同步我的 NoSQL 数据库。
在这里,我通过在 Pipeline.js 中进行以下配置正确建立了连接
var source = mongodb({ "uri": "mongodb://parentHost:27017/mongodb?authSource=admin" "tail": true})
var sink = mongodb({"uri": "mongodb://childHostName:27017/mongodb" "bulk": true});
t.Config({'write_timeout': '5000s'}).Source("source", source, "/^testing$/").Save("sink", sink, "/^testing$/");
在为源和同步数据库设置上述配置后,我使用以下方式启动了我的传输器管道:-
`transporter run Pipeline.js`
启动此管道后,在子测试集合中,我们得到的文档比父测试集合多 60 个。
最初,我们的子测试集合中没有任何文档,并且在父测试集合中有大约 278k 条记录。
如果我错过了任何配置,请您帮忙。
提前致谢 !!