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.