Cloudflare Developers

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

Join

Cloudflare Developers

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

Join

workers-help

pages-help

general-help

durable-objects

workers-and-pages-discussions

pages-discussions

wrangler

coding-help

🦀rust-on-workers

miniflare

stream

general-discussions

functions

zaraz

⚡instant-logs

email-routing

pubsub-beta

analytics-engine

d1-database

queues

workers-for-platforms

workerd-runtime

web3

🤖turnstile

radar

web-research

logs-engine

cloudflare-go

terraform-provider-cloudflare

workers-ai

browser-rendering-api

logs-and-analytics

next-on-pages

cloudflare-ai

build-caching-beta

hyperdrive

vectorize

ai-gateway

python-workers-beta

vitest-integration-beta

workers-observability

workflows-beta

vite-plugin

Saqib

10/9/2024

Hey folks, I am trying to do some

Hey folks, I am trying to do some processing on queues, surprisingly they timeout after 60s inside the consumer. On the paid plan, currently testing locally. Any thoughts? It just stops processing no error, nothing.

pao ramen

10/8/2024

Hello! I have a very misterious bug with

Hello! I have a very misterious bug with queues. I have a job that iterates a batch of 3 messages, but it only iterates 2 messages and then it never gets to the third: ``` export async function queue(batch, env) { console.log({ messages: JSON.stringify(batch.messages) }) // This logs an array of 3 objects...

Mateus Eduardo

9/30/2024

hello help me, even though the batch

hello help me, even though the batch size is 1 when I trigger a message in the queue with delay seconds of 5 minutes. After this time, this message is not sent to my consumer. Is it only triggered when I add another message to the queue?

pat

9/30/2024

Hey fellows, I've got a really simple

Hey fellows, I've got a really simple queues and d1 setup that is deployed as a worker. It is a consumer and a producer of the job that it handles. It basically uses the default wrangler.toml and I followed the tutorials on the respective page to set it up. The fetch just publishes a single event, the queue just logs it ``` export default { async fetch(request: Request<unknown, IncomingRequestCfProperties<unknown>>, env: Env, ctx: ExecutionContext): Promise<Response> {...

square

9/28/2024

Is there any plant to increase this

Is there any plant to increase this message retention period ? (https://developers.cloudflare.com/queues/platform/limits/#:~:text=retention%20period%203-,4%20days,-(96%20hours)) 4 days is too low to build any serious application. for e.g. AWS SQS has a max retention period of 14 days. I thought it would be also increased during GA announcement.

0x146231489231923

9/27/2024

5000 is so small if being used in a high

5000 is so small if being used in a high transaction system?

minty

9/26/2024

"Could not acknowledge messages"

"Could not acknowledge messages" Getting this error when trying to clear a dead-letter queue...

oof2win2

9/25/2024

you'd probably just setup one queue, set

you'd probably just setup one queue, set max batch size to 100, each queue would iterate over the request and complete it. with worker concurrency you'd have 10 workers running and getting you the results

sharax

9/23/2024

There is a simple hello world script

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

ajgeiss0702

9/20/2024

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

Hard@Work

9/19/2024

It returns an object back with which

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

tadhglewis

9/17/2024

Also, are there plans to suppport

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

tadhglewis

9/17/2024

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...

oof2win2

9/16/2024

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

kcbrewron

9/13/2024

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...

psteinroe

9/12/2024

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.

micooz

9/8/2024

Queue "consumer concurrency" feature

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

johtso

9/5/2024

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"...

Michael Wittig

9/5/2024

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...

celer

9/4/2024

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.

Previous Next

Gaming

Programming

Cloudflare Developers

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

Cloudflare Developers

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