Some updates for @Queues users:

Some updates for @Queues users: - We're working on landing HTTP Pull, which will allow you to poll a queue and consume it from outside of a Worker (or use a Worker in a poll-based flow vs. push-based). This will likely land just before/just after the holidays. - Queue throughput: our major milestone is about 3-5k msg/sec per queue (message size plays a role here), up from the ~400 msg/sec/queue currently - We're also working on landing controls around setting message delays - e.g. await env.MY_QUEUE.send(msg, { deliveryDelay: 600 }) on the producer side, and retry delays on the consumer side - e.g. messages.batch.retryAfter(300) or .retryAfter(seconds: number) on a per-message basis. API not final. - Bringing Queues to GA late Q1/early Q2 next year alongside other scaling and performance improvements.
12 Replies
trogdor
trogdor•6mo ago
Hi @Matt do you think the delay feature will be out sometime soon? Similar timeline as HTTP pull?
quambo
quambo•6mo ago
really great, looking forward to finishing our migration to cloudflare queues, with the increased throughput coming soon. is there any news on partitioning? mainly to have concurrency per some sort of group key in a single queue @Matt
elithrar
elithrar•6mo ago
Right now we are focusing on HTTP Pull + Message Delay controls + per-queue throughput before anything else. Per the pinned message: https://discord.com/channels/595317990191398933/1008691665688604783/1174739796116131920
Sz
Sz•5mo ago
Is there a beta version that is available by chance? Looking for the delay functionality similar to @trogdor
Unknown User
Unknown User•4mo ago
Message Not Public
Sign In & Join Server To View
CanRau
CanRau•3mo ago
also very interested in delaying messages, any news/eta? also http pull wouldn't yet allow to publish messages via http from outside a worker right?
sszsssszs
sszsssszs•3mo ago
When will HTTP pull rollout? I would like to replace SQS by Queues 😂
elithrar
elithrar•3mo ago
Soon - in the next 2-3 weeks.
elithrar
elithrar•3mo ago
You can write a very small Worker - since a Worker can accept HTTP requests - for that today: https://developers.cloudflare.com/queues/examples/publish-to-a-queue-over-http/
Cloudflare Docs
Queues - Publish Directly via HTTP · Cloudflare Queues
The following example shows you how to publsh messages to a queue from any HTTP client, using a shared secret to securely authenticate the client.
sszsssszs
sszsssszs•3mo ago
Wow, thanks. We can consume the message outside Worker now :facehappy:
Want results from more Discord servers?
Add your server
More Posts
Limit access to flexible images via worker?I want to only allow access to my images stored on cf images through my worker, but the issue is I wStreaming support 8k90 or 4k120? Both YT and IG support 4k60 maxHey does Cloudflare streaming support 8k90 or 4k120? Both YT and IG support 4k60 max. I want to provScript does not work with environmental variablesHi, I am using this function to get contact form submit data and send it via sendgrid. However, onceHi, could anyone explain me in simpleHi, could anyone explain me in simple terms (I would have put ELIF), why I am getting this error in What's the file structure for the drag-and-drop functionality look like?Been having trouble getting your static pages working. I have images, HTML, and CSS for multiple pagI think theres a scam page on your hostingsomeone is trying to scam me from this website -- https://rectificationsync.pages.dev/ I cannot finWebsite is super slow to load from China, anything i can do to improve it besides enterprise planSymptoms: I have a server hosted in Singapore and proxied by Cloudflare. It appears that users from Smart Placement and Service BindingsIs it possible to have a Worker that is edge-based/doesn't use Smart Placement that has a service bican you hot reload edge functions with next-on-pages?can you hot reload functions with next-on-pages? changing `page.tsx` changes the UI for me.. but do"The script will never generate a response"I have no idea where to even start looking, or even how to reproduce. I read this article https://z