dramatiq.queue.size

Current messages in queue

Dimensions:None

Technical Annotations (28)

Configuration Parameters (7)

max_agerecommended: 3600000

Maximum message age in milliseconds before discard (3600000 = 1 hour)

dramatiq_queue_prefetchrecommended: 1

For long-running tasks requiring even distribution; default ~1000 optimizes throughput

queue_namerecommended: ui-blocking

separate high-priority actors into dedicated queues

bucket_sizerecommended: 2x expected peak

prevents depletion during burst traffic

fill_raterecommended: adaptive based on queue length

tokens replenished per second, adjust dynamically

queue_prefetch

Recommended value for work_queue maxsize to prevent unbounded growth

maxsize

Attribute for queue.PriorityQueue to limit work_queue size

Error Signatures (3)

azure.core.exceptions.ResourceNotFoundError: The specified message does not existexception

MessageNotFounderror code

Unhandled error during post_process_messagelog pattern

CLI Commands (6)

dramatiq config.dramatiq --threads 1 --processes 1 --log-file=dramatiq_log${VAR}.txtdiagnostic

r.llen("dramatiq:default.DQ")diagnostic

dramatiq tasks --queues high-priority --threads 8remediation

dramatiq tasks --processes 4 --threads 8remediation

dramatiq an_app --queues defaultremediation

dramatiq an_app --queues ui-blockingremediation

Technical References (12)

message prefetchingconceptworker threadconceptdramatiq:default.DQcomponentqueue prefetchconceptwork_queuecomponentbroker.consumecomponentworker.pyfile pathdramatiq-azurecomponentpost_process_messagecomponent/usr/local/lib/python3.11/dist-packages/dramatiq/worker.pyfile path/usr/local/lib/python3.11/dist-packages/dramatiq_azure/asq.pyfile pathdead letter queuecomponent

Related Insights (10)

Message prefetching causes worker starvation with concurrent taskswarning

▸

Queue depth accumulation indicates processing bottleneckswarning

▸

Queue depth growth indicates processing cannot keep up with incoming workwarning

▸

Old messages discarded due to age limit exceededwarning

▸

Worker prefetch monopolizes queue in distributed setupcritical

▸

Slow actors on shared queues block high-priority taskswarning

▸

Token bucket depletion starves queues during burst trafficwarning

▸

Worker memory exhaustion from unbounded work queue with large message backlogscritical

▸

Azure Queue message deletion failure causes duplicate processingcritical

▸

Dead letter queue messages automatically expire after 7 daysinfo

▸