BullMQ vs Celery

import { Queue, Worker } from 'bullmq';
import { Redis } from 'ioredis';

const connection = new Redis({ maxRetriesPerRequest: null });

// Producer: add jobs to the queue
const emailQueue = new Queue('emails', { connection });
await emailQueue.add('welcome', { to: 'alice@example.com', name: 'Alice' });

// Consumer: process jobs
const worker = new Worker('emails', async (job) => {
  console.log(`Sending email to ${job.data.to}`);
  await sendEmail(job.data);
}, { connection });

from celery import Celery

app = Celery('tasks', broker='redis://localhost:6379/0')

@app.task
def send_welcome_email(user_id: int):
    user = User.objects.get(id=user_id)
    email_service.send_welcome(user.email)

@app.task
def process_upload(file_path: str):
    result = run_etl_pipeline(file_path)
    return result

# Trigger from your view:
send_welcome_email.delay(user.id)

# Run worker:
# celery -A tasks worker --loglevel=info