mongo-each

Queued asynchronous iterating over mongodb cursor

API

each(cursor, iteratee, [options])

• cursor - a mongodb cursor
• iteratee - function(doc) - iteratee function, should return promise
• options - optional
  • concurrency - how many iteratee functions should be run in parallel (default: 100)
  • batch - batch mode (default: false)
  • batchSize - batch size (default: 10)

Returns promise which is resolves when all iteratee functions have finished, or rejects if an error occurs

Example

const {MongoClient} = require('mongodb');
const each = require('mongo-each');
 
async function main() {
    const db = await MongoClient.connect('mongodb://127.0.0.1:27017/mongo-each');
    const collection = db.collection('data');
    const cursor = collection.find();
 
    await each(collection.find(), async (doc) => {
        console.log(doc)
 
        await delay(100);
    }, {concurrency: 50});
}
 
function delay(ms) {
    return new Promise((resolve) => {
        setTimeout(resolve, ms);
    });
}
 
main();

License

MIT