Adding jobs in bulk
import { Queue } from 'bullmq';
const queue = new Queue('paint');
const name = 'jobName';
const jobs = await queue.addBulk([
{ name, data: { paint: 'car' } },
{ name, data: { paint: 'house' } },
{ name, data: { paint: 'boat' } },
]);from bullmq import Queue
queue = Queue("paint")
jobs = await queue.addBulk([
{ "name": "jobName", "data": { "paint": "car" } },
{ "name": "jobName", "data": { "paint": "house" } },
{ "name": "jobName", "data": { "paint": "boat" } }
])use bullmq::{Queue, QueueOptions};
let queue = Queue::new("paint", QueueOptions::default()).await?;
let jobs = queue.add_bulk(vec![
("jobName".into(), serde_json::json!({"paint": "car"}), None),
("jobName".into(), serde_json::json!({"paint": "house"}), None),
("jobName".into(), serde_json::json!({"paint": "boat"}), None),
]).await?;Read more:
Last updated
Was this helpful?