bullmq
v5.33.1
Dragonfly เป็นการทดแทน Redis™ ใหม่ที่สามารถใช้งานร่วมกับ BullMQ ได้อย่างสมบูรณ์ และนำข้อได้เปรียบที่สำคัญบางประการเหนือ Redis™ เช่น ประสิทธิภาพที่ดีขึ้นอย่างมากโดยใช้แกน CPU ทั้งหมดที่มีอยู่ ตลอดจนโครงสร้างข้อมูลที่มีประสิทธิภาพหน่วยความจำเร็วขึ้นและมากขึ้น อ่านเพิ่มเติมที่นี่เกี่ยวกับวิธีการใช้กับ BullMQ |
องค์กรที่มีชื่อเสียงบางแห่งที่ใช้ BullMQ:
ติดตั้ง:
$ yarn add bullmq
เพิ่มงานลงในคิว:
นำเข้า { คิว } จาก 'bullmq';const คิว = คิวใหม่ ('สี');queue.add('cars', { สี: 'สีน้ำเงิน' });
ประมวลผลงานในพนักงานของคุณ:
นำเข้า { ผู้ปฏิบัติงาน } จาก 'bullmq'; const worker = ผู้ปฏิบัติงานใหม่ ('สี', งาน async => { ถ้า (job.name === 'รถยนต์') {รอ paintCar (job.data.color); -
ฟังงานให้เสร็จสิ้น:
import { QueueEvents } จาก 'bullmq';const QueueEvents = new QueueEvents('Paint');queueEvents.on('completed', ({ jobId }) => { console.log('เสร็จสิ้นการวาดภาพ');});queueEvents.on( 'ล้มเหลว', ({ jobId, failedReason }: { jobId: string; failedReason: string }) => {console.error('error painting', failedReason); -
นี่เป็นเพียงรอยขีดข่วนบนพื้นผิว ตรวจสอบคุณสมบัติทั้งหมดและอื่นๆ ในเอกสารอย่างเป็นทางการ
เนื่องจากมีโซลูชันคิวงานอยู่สองสามโซลูชัน ต่อไปนี้เป็นตารางเปรียบเทียบ:
คุณสมบัติ | BullMQ-Pro | BullMQ | วัว | คิว | ผึ้ง | กำหนดการ |
---|---|---|---|---|---|---|
แบ็กเอนด์ | ทำซ้ำ | ทำซ้ำ | ทำซ้ำ | ทำซ้ำ | ทำซ้ำ | มองโก |
สิ่งที่สังเกตได้ | ||||||
ขีดจำกัดอัตรากลุ่ม | ||||||
การสนับสนุนกลุ่ม | ||||||
การสนับสนุนแบทช์ | ||||||
การพึ่งพาพ่อแม่/ลูก | ||||||
การเด้งกลับ | ||||||
ลำดับความสำคัญ | ||||||
เห็นพ้องต้องกัน | ||||||
งานล่าช้า | ||||||
เหตุการณ์ระดับโลก | ||||||
ตัวจำกัดอัตรา | ||||||
หยุดชั่วคราว/ดำเนินการต่อ | ||||||
ผู้ปฏิบัติงานแซนด์บ็อกซ์ | ||||||
งานที่ทำซ้ำได้ | ||||||
ปฏิบัติการปรมาณู | ||||||
ความพากเพียร | ||||||
UI | ||||||
ปรับให้เหมาะสมสำหรับ | งาน/ข้อความ | งาน/ข้อความ | งาน/ข้อความ | งาน | ข้อความ | งาน |
แยก repo ทำการเปลี่ยนแปลง ส่ง pull-request! นี่คือเอกสารประกอบที่มีรายละเอียดเพิ่มเติม
ขอขอบคุณผู้มีส่วนร่วมทุกคนที่ทำให้ห้องสมุดนี้เป็นไปได้ และยังกล่าวถึง Leon van Kammen เป็นพิเศษที่กรุณาบริจาคเงิน npm bullmq repo ของเขา