javascript - Mongoose 批量更新/保存

Question

我读到 Model.collection.insert 比 Model.create 更快。​​

我在User.collection中有1kk个用户，我想每1分钟更新一次:这是我的代码:

const mongoose = require('mongoose');
const User = require('./models/user');
const async = require('async');

function getRandomArbitrary(min, max) {
    return Math.round(Math.random() * (max - min) + min);
}

User.find({}, (err, docs) => {
    async.mapSeries(docs, (doc, callback) => {
        doc.value = getRandomArbitrary(0,100);
        doc.save((err) => {
            callback(err, doc);
        });
    }, (err, result) => {
        if (err) return err;
        console.log('completed');
    });
});

这是实现这一目标的好方法吗？模式花费时间超过 1 分钟，如何提高性能？

Answer 1

您现在执行此操作的方式是等待一件事被保存，然后再转到另一件事。您可以将其并行化(完全或部分)以使其更快完成。

您可以使用 async.map 而不是 async.mapSeries 使其并行工作。

或者您可以使用async.mapLimit来限制同时发生的操作数量。

参见:

• https://caolan.github.io/async/docs.html#map
• https://caolan.github.io/async/docs.html#mapLimit
• https://caolan.github.io/async/docs.html#mapSeries

async.map 示例:

User.find({}, (err, docs) => {
    async.map(docs, (doc, callback) => {
        doc.value = getRandomArbitrary(0,100);
        doc.save((err) => {
            callback(err, doc);
        });
    }, (err, result) => {
        if (err) return err;
        console.log('completed');
    });
});

async.mapLimit 示例:

const LIMIT = 10;
User.find({}, (err, docs) => {
    async.mapLimit(docs, LIMIT, (doc, callback) => {
        doc.value = getRandomArbitrary(0,100);
        doc.save((err) => {
            callback(err, doc);
        });
    }, (err, result) => {
        if (err) return err;
        console.log('completed');
    });
});

只需将 LIMIT 设置为您想要的任何数字即可。