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.