It does't seem like the messages get redelivered when calling message.retry() with local wrangler de
It does't seem like the messages get redelivered when calling message.retry() with local wrangler dev?
17 Replies
Hi team, I need to use event notifications with R2 and queues when new objects are created. I have a job written in C#/.NET which is supposed to read messages from this queue. My question is: do you have a .NET SDK that I can use for receiving/acknowledging messages from queues? For example, I think R2 is compatible with AWS S3 SDK and I can use AmazonS3Client with R2, is that the case with queues? Can I use AmazonSqsClient with Cloudflare queues? Or what other options do I have?
yes!
You can pull via HTTP - we don’t have a .NET SDK and the SQS API is far less of a defacto standard vs S3, and so we have no plans to support it. https://developers.cloudflare.com/queues/configuration/pull-consumers/
Cloudflare Docs
Pull consumers | Cloudflare Queues
A pull-based consumer allows you to pull from a queue over HTTP from any environment and/or programming language outside of Cloudflare Workers. A pull-based consumer can be useful when your message consumption rate is limited by upstream infrastructure or long-running tasks.
Unknown User•8mo ago
Message Not Public
Sign In & Join Server To View
?crossposting
Please do not post your question in multiple channels/post it multiple times per the rules at #😃welcome-and-rules. It creates confusion for people trying to help you and doesn't get your issue or question solved any faster.
Unknown User•8mo ago
Message Not Public
Sign In & Join Server To View
I don't see why Queues won't be a good fit!
Unknown User•8mo ago
Message Not Public
Sign In & Join Server To View
I have built some demos with queues and have not faced the issues. One thing I have done to make sure that there is consistency is adding retries at the relevant places. You can also setup a dead-letter queue. Here's the doc that might be useful: https://developers.cloudflare.com/queues/configuration/batching-retries/#explicit-acknowledgement-and-retries
Cloudflare Docs
Batching, Retries and Delays | Cloudflare Queues
When configuring a consumer Worker for a queue, you can also define how messages are batched as they are delivered.
Unknown User•8mo ago
Message Not Public
Sign In & Join Server To View
It's going to be GA soon 😉
Unknown User•8mo ago
Message Not Public
Sign In & Join Server To View
You can have the producer and the consumer in the same worker or in separate ones. It really depends on how you want to architect your application. However, for now, when building locally, we recommend having them in the same worker.
https://developers.cloudflare.com/queues/configuration/local-development/#known-issues
The pricing docs have the answer on the execution: https://developers.cloudflare.com/queues/platform/pricing/
Cloudflare Docs
Pricing | Cloudflare Queues
Cloudflare Queues charges for the total number of operations against each of your queues during a given month.
Cloudflare Docs
Local Development | Cloudflare Queues
Queues support local development workflows using Wrangler, the command-line interface for Workers. Wrangler runs the same version of Queues as Cloudflare runs globally.
Unknown User•8mo ago
Message Not Public
Sign In & Join Server To View
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! 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 button in the UI is broken as well. I can see the error in the browser logs but not the UI.