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。

查看原文