Mongo-each NPM

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();