使用 Meteor 中的一次调用将多个文档插入 mongodb

Jam*_*ton 5 bulkinsert mongodb meteor

在 mongo shell 中,可以通过一次调用插入一组文档。在 Meteor 项目中,我尝试使用

MyCollection = new Mongo.Collection("my_collection")
documentArray = [{"one": 1}, {"two": 2}]
MyCollection.insert(documentArray)
Run Code Online (Sandbox Code Playgroud)

但是,当我从 mongo shell 检查 my_collection 时,它显示只插入了一个文档,并且该文档包含整个数组,就好像它是一张地图:

db.my_collection.find({})
{ "_id" : "KPsbjZt5ALZam4MTd", "0" : { "one" : 1 }, "1" : { "two" : 2} }
Run Code Online (Sandbox Code Playgroud)

是否有 Meteor 调用可用于一次性添加一系列文档,或者必须使用诸如此处描述的技术?

我想在单个调用中插入多个文档将优化客户端的性能,新文档将同时可用。

chr*_*dam 5

您可以使用批量 API在服务器端进行批量插入。使用该forEach()方法操作数组,并在循环中使用批量插入操作插入文档,批量插入操作只是服务器顶部的抽象,以便于构建批量操作。

请注意,对于比 2.6 更旧的 MongoDB 服务器,API 将向下转换操作。但是,不可能 100% 下变频,因此可能存在一些无法正确报告正确数字的边缘情况。

你可以通过原料进入在故宫的MongoDB驱动程序收集和数据库对象rawCollection,并rawDatabase在方法Mongo.Collection

MyCollection = new Mongo.Collection("my_collection");

if (Meteor.isServer) {
    Meteor.startup(function () {
        Meteor.methods({
            insertData: function() {
                var bulkOp = MyCollection.rawCollection().initializeUnorderedBulkOp(),
                    counter = 0,
                    documentArray = [{"one": 1}, {"two": 2}];

                documentArray.forEach(function(data) {
                    bulkOp.insert(data);

                    counter++;
                    // Send to server in batch of 1000 insert operations
                    if (counter % 1000 == 0) {
                        // Execute per 1000 operations and re-initialize every 1000 update statements
                        bulkOp.execute(function(e, rresult) {
                            // do something with result
                        });
                        bulkOp = MyCollection.rawCollection().initializeUnorderedBulkOp();
                    }
                }); 

                // Clean up queues
                if (counter % 1000 != 0){
                    bulkOp.execute(function(e, result) {
                        // do something with result
                    });
                }
            }
        }); 
    });
}
Run Code Online (Sandbox Code Playgroud)