Skip to content

Queue

In-memory and Redis message queue operations.

3 modules

ModuleDescription
นำรายการออกจากคิวนำรายการออกและส่งคืนจากคิว
เพิ่มรายการในคิวเพิ่มรายการไปยังคิวในหน่วยความจำหรือ Redis
ขนาดของคิวตรวจสอบขนาดปัจจุบันของคิว

Modules

นำรายการออกจากคิว

queue.dequeue

นำรายการออกและส่งคืนจากคิว

Parameters:

NameTypeRequiredDefaultDescription
queue_namestringYes-ชื่อของคิวที่จะนำรายการออก
backendstringNomemoryแบ็กเอนด์ของคิวที่จะใช้
redis_urlstringNoredis://localhost:6379URL การเชื่อมต่อ Redis
timeoutnumberNo0หมดเวลาเป็นวินาที (0 = ไม่บล็อก)

Output:

FieldTypeDescription
dataanyรายการที่นำออกจากคิว (null ถ้าคิวว่าง)
queue_namestringชื่อของคิว
remainingnumberจำนวนรายการที่เหลือในคิว
emptybooleanคิวว่างหรือไม่

เพิ่มรายการในคิว

queue.enqueue

เพิ่มรายการไปยังคิวในหน่วยความจำหรือ Redis

Parameters:

NameTypeRequiredDefaultDescription
queue_namestringYes-ชื่อของคิวที่จะเพิ่มรายการ
datastringYes-ข้อมูลที่จะเพิ่มในคิว (ค่าใดๆ ที่สามารถแปลงเป็น JSON ได้)
backendstringNomemoryแบ็กเอนด์ของคิวที่จะใช้
redis_urlstringNoredis://localhost:6379URL การเชื่อมต่อ Redis

Output:

FieldTypeDescription
queue_namestringชื่อของคิว
positionnumberตำแหน่งของรายการในคิว
queue_sizenumberขนาดปัจจุบันของคิวหลังจากเพิ่มรายการ

ขนาดของคิว

queue.size

ตรวจสอบขนาดปัจจุบันของคิว

Parameters:

NameTypeRequiredDefaultDescription
queue_namestringYes-ชื่อของคิวที่จะตรวจสอบ
backendstringNomemoryแบ็กเอนด์ของคิวที่จะใช้
redis_urlstringNoredis://localhost:6379URL การเชื่อมต่อ Redis

Output:

FieldTypeDescription
queue_namestringชื่อของคิว
sizenumberจำนวนรายการปัจจุบันในคิว

Released under the Apache 2.0 License.