Cloudflare Developers

CD

Cloudflare Developers

Welcome to the official Cloudflare Developers server. Here you can ask for help and stay updated with the latest news

Join

There is a simple hello world script

There is a simple hello world script that looks like this after connecting

Delay not working

im currently getting ratelimited by an external service because things that are supposed to be delayed (using queues) are all getting run at once

It returns an object back with which

It returns an object back with which messages to retry/ack

Also, are there plans to suppport

Also, are there plans to suppport passing a Message into an RPC Worker?

Learn how to configure a dead-letter que...

Couple queries: Any plans to add a Message.deadletter method? I have some use cases where I know the message will always fail and it needs manual triage. It'd be great to have redrive functionality to move messages from the deadletters to processing queue once any issues with the deadletters have been resolved (e.g. temp outage). AWS SQS has similar functionality https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-configure-dead-letter-queue-redrive.html...

is there a plan to have messages be "

is there a plan to have messages be "grouped" and sent that way? i have a merchantId prop on my messages and i want to handle up to 20 messages per merchant, but there isn't really a way to do that right now

I haven't run into messages dropping or

I haven't run into messages dropping or batches dropping. I have built some interesting architecture where I have a message-producer API which abstracts all the applications from needing to know about how to send messages. We used a KV bound to the message producer API to know what queue to route to and bind the worker to any queue. I know there are limits to the binding, but this API has made it easy to onboard queues for a few different use cases. I'm ready for this to move to GA. What issues...

hey! is there any (inofficial) goal for

hey! is there any (inofficial) goal for queues performance? will it ever be comparable to eg sqs? sending to the queue is currently multiiple 100ms, and it takes multiple seconds for a worker to receive it. and throughput is much much lower at the moment.

Queue "consumer concurrency" feature

Queue "consumer concurrency" feature does not seem to be suitable for scenarios that rely on sequential execution.

hmm, it seems like my messages are being

hmm, it seems like my messages are being retried immediately after an implicit retry instead of waiting the configured 60 seconds.. ```toml [[env.staging.queues.consumers]] queue = "emails-staging"...

Hi! I deleted a bunch of R2 bucket

Hi! I deleted a bunch of R2 bucket notifications & buckets but I can not delete the queue that was referenced. I always receive the error "cannot delete queue bucketav-rhyglnin that serves as a target for event notifications". I have no buckets left so this is likely not the case. Are there any reqasons for that? Is there something happening in the background before I can delete the queue? If I look at the queue in the dashboard it says "This queue does not have a consumer". Clicking the delete...

Hi! Has anyone seen CPU Execution

Hi! Has anyone seen CPU Execution timeout on queue consumer event? In the worker limits docs they say the limit is 15 minutes of CPU time. But I always get timeout after 32,000ms (according to the worker cpu time dashboard). I could work around that, but I'd like to know if the docs are wrong or if it's a bug on my or CF side.

Hi, new to queues. I'm doing this:

Hi, new to queues. I'm doing this: ```ts await env.queue.send( data, { delaySeconds: 42300, contentType: "json" }...

I think I might be seeing some messages

I think I might be seeing some messages dropped from my queue? Some final data in our db is missing and I traced it back to this. Cloudflare dashboard shows 321 messages successfully delivered Logpush logs only show 313 events from that queue ...

Hey team, whats up?

Hey team, whats up? I have a use case for queues and want to know if my logic is correct: - I have a producer that posts around 500 messages at once on the queue, using batches of 25 messages - All batches are delayed incrementally until the last batch on increments of 30 seconds each batch (first batch for 0 seconds, the second for 30 seconds, the third for 60 seconds...)...

Is there a way to force a queue to

Is there a way to force a queue to increase concurrency, or to set a minimum concurrency? I'm seeing the following behaviour now: I have a queue where only once every 1-5 minutes, a message is queued. A message takes about 30 seconds wall time to be processed. Maximum consumer concurrency is on default....

Ideally queues could allows us to list

Ideally queues could allows us to list pending messages

Hey people!

Hey people! When developing locally, I have configured my queue with following retry timeouts and counts: ``` max_retries = 10, ...

Hi, how do I deal with queue consumer

Hi, how do I deal with queue consumer timeout issue? i.e. make sure queue consumer completed the task with payload? Is there anyway to have queue retry calling consumer unless consumer explicitly acknowledge the payload was processed susessfully?