Предположим, вам нужно добавить большое количество данных в вашу базу данных. Недостатком, если вы не используете систему очередей в node.js, является то, что иногда поля документа могут быть сохранены пустыми в вашей базе данных MongoDB. Таким образом, чтобы убедиться, что все данные были отправлены, используйте систему очередей. Одним из решений может быть использование пакета better-queue, который прост в использовании и имеет большое количество загрузок в неделю.
// Пример:
const Queue = require(“better-queue”);
const User = require(“../models/User”);
let users=[{
name: «Rahul»,
age: «25»}] // Допустим, есть огромное количество данных
// Реализация Queue
const q=new Queue(async function(input, cb){
const result = await User.create(input);
cb(null, result)
})
// desc Создать пользователя
exports.createUser=async(req,res)=›{
try{
for(i=0;i‹users.length;i++){
q.push({пользователи[i]})
}
// Убедиться, что очередь пуста и все данные отправлены
q.on('drain', function () {
res.status(200).json({ message: 'Данные успешно добавлены ' });
})
}catch(error){
res.json("Что-то пошло не так")
}
}
И вот как вы можете реализовать простую систему очередей в node.js
