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:6379Redis 連線 URL
timeoutnumberNo0以秒為單位的超時時間(0 = 非阻塞)

Output:

FieldTypeDescription
dataany取出的項目(如果佇列為空則為 null)
queue_namestring佇列名稱
remainingnumber佇列中剩餘的項目
emptyboolean佇列是否為空

加入項目

queue.enqueue

將項目新增到記憶體或 Redis 佇列中

Parameters:

NameTypeRequiredDefaultDescription
queue_namestringYes-要新增項目的佇列名稱
datastringYes-要加入佇列的資料(任何可被 JSON 序列化的值)
backendstringNomemory要使用的佇列後端
redis_urlstringNoredis://localhost:6379Redis 連線 URL

Output:

FieldTypeDescription
queue_namestring佇列名稱
positionnumber項目在佇列中的位置
queue_sizenumber加入後佇列的當前大小

佇列大小

queue.size

獲取佇列的當前大小

Parameters:

NameTypeRequiredDefaultDescription
queue_namestringYes-要檢查的佇列名稱
backendstringNomemory要使用的佇列後端
redis_urlstringNoredis://localhost:6379Redis 連線 URL

Output:

FieldTypeDescription
queue_namestring佇列名稱
sizenumber佇列中當前的項目數

Released under the Apache 2.0 License.