queues

SKILL.md

Build reliable asynchronous message processing on Cloudflare Workers using Queues for background tasks, batch operations, and retry handling.

| Send single message | env.QUEUEBINDING.send(payload) | | Send batch | env.QUEUEBINDING.sendBatch([msg1, msg2]) | | Define consumer | async queue(batch: MessageBatch, env: Env) { ... } | | Access message body | batch.messages.map(msg => msg.body) | | Acknowledge message | Messages auto-ack unless handler throws |

| Retry message | throw new Error() in queue handler | | Get batch size | batch.messages.length |

用于可靠后台处理的异步消息队列。在卸载后台任务、批处理消息、使用死信队列实现重试逻辑、限制上游 API 速率或将生产者与消费者解耦时加载。 来源：null-shot/cloudflare-skills。

查看原文