Cloudflare Developers•2y ago

is there a way to send data into a queue via the REST api or do I have to write a worker to wrap it?

Sswitz is there a way to send data into a queue via the REST api or do I have to write ...

Matt Silverlock•4/4/24, 7:27 PM

You'll need to write a Worker: https://developers.cloudflare.com/queues/examples/publish-to-a-queue-over-http/

you can consume from any HTTP client, but you'll need a Worker to write to a Queue for now.

switzOP•4/4/24, 7:27 PM

yeah, that's what I did. would be nice if you could off the shelf with the REST api/cloudflare typescript package. but only took me ~10 mins to write one myself

switzOP•4/4/24, 11:00 PM

is there a way to add an idempotent id for a queue message to avoid duplicate messages for messages that may already be in a queue?

my use case is: occasionally if an external entity is not cleaned up, I may send a message to a queue to clean it up – but if that message hasn't been handled yet, I'd rather not continue filling up the queue with the same message.

alternatively, if there's a way to see if the queue has a message that would also be helpful.

kalepail•4/4/24, 11:09 PM

It seems that delaySecondsdelaySeconds doesn't work locally. Is this being tracked anywhere or should I open an issue?

maciej•4/5/24, 11:12 AM

Hey, what are the plans around supporting Pages Functions as queue consumers? Is it something on the roadmap?

Kkalepail It seems that `delaySeconds` doesn't work locally. Is this being tracked anywher...

se•4/5/24, 3:09 PM

We are aware of that and it's being tracked. We have WIP for that.

Bryan•4/5/24, 5:00 PM

Is there any plan for supporting message de-duplicate?

Sometimes I want to retry sending a message, but I don't want it to be handled twice more. Many message queue can set a custom MessageId for message de-duplication. Will queues support it?

Unsmart•4/5/24, 6:00 PM

You should always make your queue handler idempotent. It will always be possible that a single message be replayed twice (or more).

Victor•4/6/24, 9:00 PM

I found an weird inconsistency in batch timeout. Miniflare validator of wrangler.tomlwrangler.toml says Number must be less than or equal to 30Number must be less than or equal to 30, the limits doc page (https://developers.cloudflare.com/queues/platform/limits/#limits) says max 3030, but the browser rendering example shows 6060 https://developers.cloudflare.com/queues/tutorials/web-crawler-with-browser-rendering/#3-configure-your-worker and the web gui says max 6060

Cloudflare Docs

Limits · Cloudflare Queues

Many of these limits will increase during Queues’ public beta period. Follow our changelog or join the #queues-beta channel in our Developer Discord …

Cloudflare Docs

Cloudflare Queues - Queues & Browser Rendering · Cloudflare Queues

This tutorial explains how to build and deploy a web crawler with Queues, Browser Rendering, and Puppeteer.

VVictor I found an weird inconsistency in batch timeout. Miniflare validator of `wrangle...

Victor•4/6/24, 11:23 PM

Opened https://github.com/cloudflare/cloudflare-docs/issues/13894

GitHub

Queues Batch timeout inconsistencies · Issue #13894 · cloudflare/cl...

Existing documentation URL(s) https://developers.cloudflare.com/queues/platform/limits/#limits https://developers.cloudflare.com/queues/tutorials/web-crawler-with-browser-rendering/#3-configure-you...

boywonder350•4/7/24, 3:26 AM

I am trying out the new r2 events with a queue and I am noticing it is pretty slow. My process is on photo upload, listen for the event in a queue and have a worker generate 10 variations with image transformation and then store the variations in r2 and then save all the info in a db. I stress tested the system by uploading 200 images (with 4 concurrently uploaded at a time) and noticed that after the images uploaded, the queue worker is still working on processing the events like 10 minutes later. Not sure if this is just a beta thing, but I was hoping this would have better results. Anyone know whats up with this?

Bboywonder350 I am trying out the new r2 events with a queue and I am noticing it is pretty sl...

Matt Silverlock•4/7/24, 10:23 AM

What do you mean by slow? Slow for it to receive the events in the first place, or to process them in your consumer? What are your batch settings?

Can you share your code if it’s the latter? The consumer is only going to be as fast as the code you write / the work it needs to do.

MMatt Silverlock What do you mean by slow? Slow for it to receive the events in the first place, ...

boywonder350•4/7/24, 1:18 PM

Also here is the stats for the worker processing it. Wall time means the amount of time it took the worker to process the message right? What is the max amount of workers that can take a queue message and process it? It feels like it is slow to process the events to spin up a worker.

Bboywonder350 Also here is the stats for the worker processing it. Wall time means the amount ...

Matt Silverlock•4/7/24, 4:25 PM

https://developers.cloudflare.com/queues/reference/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 …

MMatt Silverlock https://developers.cloudflare.com/queues/reference/consumer-concurrency/

boywonder350•4/7/24, 4:29 PM

Are there any available metrics to see how many consumer workers were used for a duration? Following the documentation, I am looking for max concurrency and I only find this:
"Concurrent consumer invocations 20 push-based only"

What does it mean to be "push-based only" here?

Bboywonder350 Are there any available metrics to see how many consumer workers were used for a...

Matt Silverlock•4/7/24, 7:34 PM

https://developers.cloudflare.com/queues/reference/how-queues-works/#consumers

Cloudflare Docs

How Queues Works · Cloudflare Queues

Cloudflare Queues is a flexible messaging queue that allows you to queue messages for asynchronous processing. Message queues are great at decoupling …

boywonder350•4/7/24, 7:54 PM

I guess the slowness was due to there only being 20 concurrent consumers. Will this ever change?

boywonder350•4/7/24, 7:54 PM

The issue is for one image upload, I then create 10 variations. I then need to no-op the consumer worker for those 10 items because I don’t want to process them

Bboywonder350 The issue is for one image upload, I then create 10 variations. I then need to n...

Matt Silverlock•4/7/24, 9:52 PM

Why not set up Event Notifications to only send you events for objects matching a certain prefix, or write to a different bucket, to avoid handling events you don’t want to process? Otherwise just ack()ack() those messages and move on.

boywonder350•4/7/24, 9:56 PM

ooo totally fixxed the prefix or suffix documentation!

DanGamble•4/8/24, 9:42 AM

Given you can't use a pages app and a separate worker to consume a queue locally what is people's current workflows for handling this? I was thinking of deploying a queue and then just using that but I'm not sure how to have 1 binding be remote but the rest local

serkanozal•4/8/24, 6:28 PM

Hi everyone,

I am experimenting with Cloudflare Workers and Queues. During my experiments, I have noticed that sending a simple message from my Cloudflare Worker to a binded Cloudflare Queue takes about 200 ms in the warm invocations. Is this expected? Might it be caused by network latency if the binded queue is used from another data center or is it just Cloudflare Queue slow?

Especially comparing with AWS SQS send message latency, it seems too much to me. Because according to my experiments, it is around 10 ms for sending a message to AWS SQS queue, but it is 200 ms for Cloudflare Queue.

Original message was deleted

Matt Silverlock•4/8/24, 7:40 PM

It should look like this: https://developers.cloudflare.com/api/operations/queue-v2-messages-ack

Cloudflare API Documentation

Interact with Cloudflare's products and services via the Cloudflare API

Original message was deleted

Matt Silverlock•4/8/24, 8:07 PM

Can you confirm the path you’re hitting, just to be sure?

Original message was deleted

Matt Silverlock•4/8/24, 8:17 PM

The undocumented one is deprecated (and will be removed in future). Let me add a note to the docs just to be sure.

Original message was deleted

Matt Silverlock•4/8/24, 8:39 PM

https://github.com/cloudflare/cloudflare-docs/pull/13924

GitHub

queues: clarify undocumented endpoints by elithrar · Pull Request #...

cc @w-kuhn

John Spurlock•4/9/24, 11:07 PM

did queues conk out for about 5 minutes last hour? No messages delivered to queuequeue from around 5.23pm to 5.28pm us central

MMatt Silverlock You can apply an exponential back off on each attempt - we’ll soon be exposing t...

Matt Silverlock•4/10/24, 11:30 AM

@Florian the attemptsattempts field on messages has shipped. Docs PR (waiting on build): https://github.com/cloudflare/cloudflare-docs/pull/13648

GitHub

[QUEUES] Document how to apply a backoff alg by elithrar · Pull Req...

Documents how to apply a backoff alg when calling retry().

JJohn Spurlock did queues conk out for about 5 minutes last hour? No messages delivered to `qu...

Matt Silverlock•4/10/24, 1:05 PM

No widespread issues - queue ID?

Hhannes afaik queues run only in loctions where DOs run, which is like 12% of all Cloudf...

serkanozal•4/10/24, 5:36 PM

Thanks for the detailed answer. Is there any way to verify this (location of the queue colo)?

Original message was deleted

Matt Silverlock•4/11/24, 10:18 PM

You can change the # count in the UI - right above the picker. There isn’t pagination though due to the way Queues works right now.

Hhannes Hrm the queue worker should be able to fetch “/cdn-cgi/trace” and parse the colo...

serkanozal•4/12/24, 9:20 AM

When I request to the "<MY-DOMAIN>/cdn-cgi/trace", the colo in the response is "FRA". But as far as I understood, it is the colo of my worker, but CloudFlare queue might be served from another colo. Or does it mean that the queue itself is used from colo "FRA" too? If so, why the latency is so high (200ms)?

Hhannes Hrm the queue worker should be able to fetch “/cdn-cgi/trace” and parse the colo...

serkanozal•4/12/24, 9:26 AM

Also, when I call the "https://api.cloudflare.com/client/v4/accounts/<account-id>/queues/<queue-id>/messages/pull" endpoint to get message from queue, I have seen that it is responded from "FRA" colo as far as I see from the "CF-Ray" header. So does it mean that queue operation is handled at "FRA" colo, or still might it be the case that "FRA" colo gets the queue API request but it forwards to another colo (or data center) to handle the request, but since "FRA" colo is the entry point, we only see it in the "CF-Ray" header.

MMatt Silverlock No widespread issues - queue ID?

John Spurlock•4/12/24, 3:54 PM

just happened again from around 9.03 to 9.08am us central - same queue (d3ec8122f30d4d69a7512199d25ce93bd3ec8122f30d4d69a7512199d25ce93b)

John Spurlock•4/12/24, 9:47 PM

any guidance on what to do when receiving Error: Queue send failed: Internal Server ErrorError: Queue send failed: Internal Server Error calling queue.sendqueue.send ? I am retrying a few times backing off on the order of seconds, but the same error is thrown. Should these errors not be considered retryable?

Vikash•4/13/24, 12:50 PM

My queue is not sending any messages to the consumer, anyone from Cloudflare can help?

I already tried to disconnect > re-connect the consumer.

Vikash•4/13/24, 12:50 PM

Queue ID: 2610e093592e446f8fc0fe23632c527a

Vikash•4/13/24, 12:50 PM

Consumer details -

Sameer Ali•4/13/24, 9:06 PM

I am looking at REST API and trying to figureout how i can push messages to a queue outside of worker.

Sameer Ali•4/13/24, 9:06 PM

is there any way i can do this without creating a worker and push from there?

SSameer Ali is there any way i can do this without creating a worker and push from there?

John Spurlock•4/13/24, 10:34 PM

nope, a worker is the only way right now

https://developers.cloudflare.com/queues/examples/publish-to-a-queue-over-http/

Sameer Ali•4/13/24, 10:58 PM

Thanks John!

Fabian•4/16/24, 6:02 PM

Is there any plan to support grouping messages by an identifier? For example, I want to create batches of messages that (at best) all are "from" one customer ("the grouping key"). It would be only the preferred way of grouping batches, they still can consist of very different grouping keys though.
This is to send data to an upstream service and right now it would be like the following example:

Set max queue concurrency to 1 since upstream does not allow more than 100 req/s
batch_size to 100 (and in my case max wait time to 30sec because speed does not really matter)
Upstream also has a per-customer batching, not per message/action
Now the requests are worst case 100x more than needed - imagine 100 customers producing 3 messages every second. Instead of 3 batches consisting of data that can be grouped together to one request, I now have to make 100 requests, artificially "wait 1 second" and let the backlog grow. Otherwise the wait would not be required and the next batch could immediately be processed, since only 1 request of the max 100req/s was used

I don't know if this is a very specific use-case, but I imagine grouping by something could generally be applied for more things, increasing overall efficiency

Fabian•4/16/24, 6:09 PM

I'm considering not using queues altogether because of this and just group them in a database and run a scheduler like every hour/minute/whatever and pull data out of the DB. Even though the concept of a queue would be a perfect fit in my opinion.

is there a way to send data into a queue via the REST api or do I have to write a worker to wrap it?

Similar Threads

Similar Threads

Similar Threads