0

我正在使用传输器管道在源数据库 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 条记录。

如果我错过了任何配置,请您帮忙。

提前致谢 !!

4

0 回答 0