thank you very much. You just solved an issue i've been having for weeks and could not find a soluti

thank you very much. You just solved an issue i've been having for weeks and could not find a solution for!

NoGameNoFun•12/2/24, 6:54 AM

hi, i trying to set the cpu ms limit for the worker that run as consumer of a queueu, based on the documentation, it suppose can set a max limit of 15 minutes of cpu run limit, but when i try to set via wrangler or even using the dashboard, both i got is max 30,000 ms only

Aajgeiss0702 thank you very much. You just solved an issue i've been having for weeks and cou...

Poyo•12/2/24, 1:18 PM

No problem. It has only taken me two days

I think the issue here is that the queue is not a standard worker. It has extra limitations that nobody is mentioning anywhere. Something to add to the docs as it will save so much time

Poyo•12/2/24, 1:24 PM

By the way, when you run a browser in the queue directly, it keeps spinning until it exhausts all the CPU, and only after that does it time out. That is why we were seeing these random long waiting times. The browser blocks the consumer from execution until it times out, but it is my guess. I'm glad that I was able to help.

NNoGameNoFun hi, i trying to set the cpu ms limit for the worker that run as consumer of a qu...

Poyo•12/2/24, 1:40 PM

My assumption is that a queue consumer is not a standard worker. I would also use a Durable Object - basically a separate normal worker connected to your queue consumer

queues

PPoyo By the way, when you run a browser in the queue directly, it keeps spinning unti...

ajgeiss0702OP•12/2/24, 4:34 PM

I can basically confirm it is some issue with browser rendering + queues. The only thing I changed was moving the browser rendering logic to a DO and calling that instead of it just being a function in my consumer. The rest of the logic is the same, and I have not had the issue since making that change

Sami•12/3/24, 3:07 AM

Hi, is there a way to find how many outstanding items/messages are present in a queue? Especially, to use with pull-workers.

juanferreras•12/3/24, 1:51 PM

I thought queues was not working reliably because I was seeing some unprocessed rows in my database from time to time.
Actually, I had a

try/catch

try/catch

on my consumer worker so I was swallowing the errors myself haha. Turns out I was the unreliable one and queues works great

go•12/4/24, 10:19 AM

I am using a cron once a day to fetch items from my database, add them to a queue, and process the items. However, as the cron is adding tens of thousands of items to the queue, I am reaching the limit of worker invocations I can do (1000 per worker). What are recommended ways to handle this kind of large batch processing in Workers?

Ggnomesgames Hi! I’ve got a worker being called as a webhook from an external service (which ...

James•12/4/24, 3:00 PM

Nope, the consumer is run concurrently. You need a programmatic way to make these sequential as the more messages you queue, the single consumer scales up to consume on demand.

But if you chain messages via the queue, that would work.

Ggnomesgames Hi! I’ve got a worker being called as a webhook from an external service (which ...

Brett Willis•12/4/24, 6:18 PM

You can set max_concurrencymax_concurrency to

so that your consumer will be invoked only one at a time.
Each invocation can still of course contain a batch of multiple messages depending on your max_batch_sizemax_batch_size setting.
https://developers.cloudflare.com/queues/configuration/consumer-concurrency/

Cloudflare Docs

Consumer concurrency · Cloudflare Queues

Consumer concurrency allows a consumer Worker processing messages from a queue to automatically scale out horizontally to keep up with the rate that messages are being written to a queue.

Stefan Stührmann•12/4/24, 9:38 PM

Hey, is there any timeline when you plan to support running separate producer and consumer Workers bound to the same Queue locally? Usually you use queues to decouple your application therefore it is quite uncomfortable to not have the same level of local development on queues then on other Cloudflare components. And yes I'm already aware that I can trick this by "wiring" the consumer handler into the worker into the handler of the producer worker using the queue handler function out of the other worker and managing the consumer / producer mapping via wrangler.toml. It's just uncomfortable. (https://developers.cloudflare.com/queues/configuration/local-development/#known-issues)).

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.

ajgeiss0702OP•12/4/24, 10:35 PM

im having a weird issue with one of my queues.
The queue itself is suddenly (as of this week) processing messages much slower than it used to. No changes have been pushed to the consumer at all in the past 7 months

Additionally, every time I try to look at the queue in the dashboard, the dashboard crashes

queue id is a11bfcc288144990acb3a9f0ba8c5adfa11bfcc288144990acb3a9f0ba8c5adf

ajgeiss0702OP•12/4/24, 10:36 PM

and this is what I mean by the dashboard crashing. This happens after clicking on the queue. I see the queue metrics page start to load, then it switches to this less than a second later

ajgeiss0702OP•12/4/24, 10:38 PM

and there is this error message in the browser console

Tilo•12/5/24, 12:16 PM

Hey, I have a app which uses browser rendering and queues in the same worker. So far I used wrangler dev --remote to develop the browser part, I wanted to add the queue but ran into the issue, that queues are not supported in remote dev. What is a possible solution here?

patotoma•12/6/24, 4:01 AM

Is there something wrong with Queues? Most of my messages are failing to deliver for what they normally works.

James•12/6/24, 4:46 AM

I cannot load any queues on my cloudflare dashboard, the dashboard site breaks when I click on any. Any help?

JJames I cannot load any queues on my cloudflare dashboard, the dashboard site breaks w...

Isaac McFadyen•12/6/24, 4:50 AM

Hey. Mind sending your account ID (it's fine to make it public, it's not secret info) and I can see if I can escalate this?

Isaac McFadyen•12/6/24, 4:51 AM

Given that a user was having the same issue the other day there's likely a bug in the Queues dashboard.

IIsaac McFadyen Hey. Mind sending your account ID (it's fine to make it public, it's not secret ...

James•12/6/24, 4:52 AM

sent thank you

JJames I cannot load any queues on my cloudflare dashboard, the dashboard site breaks w...

Isaac McFadyen•12/6/24, 3:42 PM

Hey - this is being investigated by the team, thanks for the report.

JJames I cannot load any queues on my cloudflare dashboard, the dashboard site breaks w...

Pranshu Maheshwari•12/6/24, 9:24 PM

We've found the issue here: the fix should roll out soon!

Walshy•12/6/24, 9:52 PM

Should be out and fixed

kimjongillest•12/12/24, 3:01 AM

is the best way to segregate HTTP access for queues to manage secrets within a worker?

eg: client calls a normal worker rest endpoint and passes the secret, then the worker does a switch statement to correctly forward the message to a queue while checking the secret against that queue name using a map?

Aries•12/17/24, 6:44 PM

Is there a way to de-dupe queue items, ie, have a unique-by key, which will ensure it is in the queue only once?

Aries•12/17/24, 6:45 PM

optimally, you'd be able to specific a key when writing a message.

sup filistine•1/5/25, 1:55 AM

maybe a short question on queues: x-posting from workers-help: workers-and-pages-helpQueues are not scaling up, consumer wise when using a regular (non pull consumer)

joezief•1/8/25, 4:29 PM

is there a good example anywhere of testing retry mechanism of queue consumer using vitest?

jacky•1/9/25, 9:33 AM

guys i got over an hour of consumer delay, is this normal?

slagathor•1/10/25, 4:39 PM

I currently have a queue setup where the consumer worker initiates a CSV download from an API, continues to poll the API until the CSV is available, downloads the CSV, and then stores it in R2.

Right now only 2 messages are getting sent to the queue at a time (via a cron job at the top of every hour), but only the first one ever gets processed (it's processed to completion).

Could this be a CPU limit issue? I don't see any error logs. These are my current .toml settings:

max_batch_size = 1
max_retries = 0

max_batch_size = 1
max_retries = 0

Suman!•1/11/25, 6:04 AM

Hi guys, is there a way i can export all the messages from my dead letter queue? Or may be to list all the messages
I am unable to get to read the latest messages from the dashboard since there are 4-500s of messages.

ViVi•1/11/25, 6:43 AM

In the tunnel, I tried to configure public host name for a localhost:port. Everything worked flawlessly.
However, when I tried to configure a https://username.subdomain.usbx.me/jellyfin:8096, it didn't work at all.
Where did I miss on the config process?

John Spurlock•1/11/25, 10:47 PM

hmm, I'm stumped, getting this 403 error message from the api when trying to pull messages from a particular queue: messages cannot be pulled unless http_pull mode is enabledmessages cannot be pulled unless http_pull mode is enabled

the queue has a single consumer of type http_pullhttp_pull, which I thought was the key to defining "http_pull mode":

{
  "queue_id": "8c720189e5c54eefa03f53eefb7162f1",
  "queue_name": "queue2-ci-dlq",
  "settings": {},
  "created_on": "2024-03-10T18:25:36.141403Z",
  "modified_on": "2024-03-10T18:25:36.141403Z",
  "producers_total_count": 0,
  "producers": [],
  "consumers_total_count": 1,
  "consumers": [
    {
      "settings": {
        "batch_size": 10,
        "max_retries": 100,
        "visibility_timeout_ms": 30000,
        "retry_delay": 0
      },
      "consumer_id": "d2a3644fd6cc40fab4e023ce65c451dc",
      "type": "http_pull"
    }
  ]
}

{
  "queue_id": "8c720189e5c54eefa03f53eefb7162f1",
  "queue_name": "queue2-ci-dlq",
  "settings": {},
  "created_on": "2024-03-10T18:25:36.141403Z",
  "modified_on": "2024-03-10T18:25:36.141403Z",
  "producers_total_count": 0,
  "producers": [],
  "consumers_total_count": 1,
  "consumers": [
    {
      "settings": {
        "batch_size": 10,
        "max_retries": 100,
        "visibility_timeout_ms": 30000,
        "retry_delay": 0
      },
      "consumer_id": "d2a3644fd6cc40fab4e023ce65c451dc",
      "type": "http_pull"
    }
  ]
}

tried removing/re-adding the pull consumer, double-checked the token has edit-queue permission, anyone else seen this before?

JJohn Spurlock hmm, I'm stumped, getting this 403 error message from the api when trying to pul...

ajgeiss0702OP•1/12/25, 4:17 PM

Have you tried enabling it via wrangler?

https://developers.cloudflare.com/queues/configuration/pull-consumers/#wrangler-cli

Cloudflare Docs

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

Aajgeiss0702 Have you tried enabling it via wrangler? https://developers.cloudflare.com/queu...

John Spurlock•1/12/25, 7:10 PM

yes, and through the dashboard - the config seems correct, it's similar to a prod dlq queue in that same account which works fine - it's just that queue 8c720189e5c54eefa03f53eefb7162f18c720189e5c54eefa03f53eefb7162f1 that gives messages cannot be pulled unless http_pull mode is enabledmessages cannot be pulled unless http_pull mode is enabled. I even tried previewing and deleting the 3 messages in there, didn't help

xintercept•1/15/25, 12:37 AM

anyone else run into problems with queues today? we hit a bunch of "Queue send failed: Service Temporarily Unavailable" around 2025-01-14T19:51:06.333Z

Xxintercept anyone else run into problems with queues today? we hit a bunch of "Queue send f...

xintercept•1/15/25, 12:38 AM

(doesn't look like anything was reported on https://www.cloudflarestatus.com/ related to Qs either)

Cloudflare Status

Welcome to Cloudflare's home for real-time and historical data on system performance.

chhatra_•1/15/25, 6:52 AM

Hello , I am building some application with cloudflare queues and worker . My consumer worker code checks if the system is free then it sends message from the queue to the system else the queue retries after cetain time 1200s .the queue retries the message but after delayed time has passed messages , the message is not processed from the queue but when I make a new request to the queue then the new message and previous message is processed ?

chhatra_•1/15/25, 6:53 AM

How to fix this ? what could be the causes for it . I want the consumer to automatically process the message after the retry time has passed

chhatra_•1/15/25, 7:04 AM

Does anyone know what settings should check ?

chhatra_•1/16/25, 3:42 AM

Actually , the queue was working fine previously . I noticed multiple repeatative requests from diffrent user agent so I applied code to filter that out. After that this happen, I commented out the code that filter it out on the basis of user agent , still it got the same problem. I had lost my original source code when my laptop broke down. I noticed to many requests on my queue so I made changes using the GUI interface provided by cloudflare. Directly modifying the compiled code . Can not using wrangler cli be a cause of this problem ?

Cchhatra_Hello , I am building some application with cloudflare queues and worker . My co...

Rakhim•1/16/25, 12:14 PM

Have you considered using Workflows instead? It feels better suited for retries/fallback scenarios, you can define the retry and backoff policy per workflow, and it can also sleep for long periods of time.

kcbrewron•1/17/25, 4:51 PM

Not sure this is the right channel but nothing for notifications that I saw. I would love to see the ability to configure notifications when my dlq reaches a certain threshold without having to query the metrics API constantly

allen•1/18/25, 11:49 AM

Hi
I'm using Cloudflare Workers and I'm passing messages between them using Queues. Within a batch of messages the code iterates over the messages in a for loop and after processing each message it explicitly acks the message, eg message.ack(). Despite this the message gets redelivered and the queue fills up with messages until they run out of retries.

ack'ing the batch doesn't work either (batch.ackAll()) and not acking at all and just returning also has no effect. So for now I've set the queus to have max_retries = 0 and no DLQ. Is there something obvious maybe that I've missed?

I'm going to head out now to try and enjoy the rest of my Saturday

sadel•1/18/25, 5:45 PM

would be amazing if you guys could add an extra configuration to queues for max dispatches / second so that we can fully wrap 3rd party apis and stay within rate limits

thank you very much. You just solved an issue i've been having for weeks and could not find a soluti

Similar Threads

Similar Threads

Similar Threads