Skip to content

Commit f38556f

Browse files
maheshwariphyperlint-ai[bot]Oxyjun
authored andcommitted
Queues GA
* Removed beta tags and updated limits * Removed queues from betas list * removed beta flags and typos * Removed partial to request Queues access * Update src/content/docs/queues/get-started.mdx Co-authored-by: hyperlint-ai[bot] <154288675+hyperlint-ai[bot]@users.noreply.github.com> * Update src/content/docs/queues/index.mdx * Update src/content/partials/queues/enable-queues.mdx * Updated queues changelog --------- Co-authored-by: hyperlint-ai[bot] <154288675+hyperlint-ai[bot]@users.noreply.github.com> Co-authored-by: Jun Lee <[email protected]>
1 parent 9341441 commit f38556f

File tree

9 files changed

+32
-61
lines changed

9 files changed

+32
-61
lines changed

src/content/changelogs/queues.yaml

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,15 @@ productLink: "/queues/"
55
productArea: Developer platform
66
productAreaLink: /workers/platform/changelog/platform/
77
entries:
8+
- publish_date: "2024-09-26"
9+
title: Queues is GA, with higher throughput & consumer concurrency
10+
description: |-
11+
Queues is now generally available.
12+
13+
The per-queue message throughput has increased from 400 to 5,000 messages per second. This applies to new and existing queues.
14+
15+
Maximum concurrent consumers has increased from 20 to 250. This applies to new and existing queues. Queues with no explicit limit will automatically scale to the new maximum. Review the [consumer concurrency documentation](/queues/configuration/consumer-concurrency) to learn more.
16+
817
- publish_date: "2024-03-26"
918
title: Delay messages published to a queue
1019
description: |-

src/content/docs/queues/configuration/consumer-concurrency.mdx

Lines changed: 2 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -68,7 +68,7 @@ To configure the concurrency settings for your consumer Worker from the dashboar
6868
2. Select **Workers & Pages** > **Queues**.
6969
3. Select your queue > **Settings**.
7070
4. Select **Edit Consumer** under Consumer details.
71-
5. Set **Maximum consumer invocations** to a value between `1` and `10`. This value represents the maximum number of concurrent consumer invocations available to your queue.
71+
5. Set **Maximum consumer invocations** to a value between `1` and `250`. This value represents the maximum number of concurrent consumer invocations available to your queue.
7272

7373
To remove a fixed maximum value, select **auto (recommended)**.
7474

@@ -97,7 +97,7 @@ To remove the limit, remove the `max_concurrency` setting from the `[[queues.con
9797
### wrangler CLI
9898
9999
```sh
100-
# where `N` is a positive integer between 1 and 10
100+
# where `N` is a positive integer between 1 and 250
101101
wrangler queues consumer update <script-name> --max-concurrency=N
102102
```
103103
@@ -120,7 +120,3 @@ Billing for consumers follows the [Workers standard usage model](/workers/platfo
120120
### Example
121121

122122
A consumer Worker that takes 2 seconds to process a batch of messages will incur the same overall costs to process 50 million (50,000,000) messages, whether it does so concurrently (faster) or individually (slower).
123-
124-
```
125-
126-
```

src/content/docs/queues/configuration/javascript-apis.mdx

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,7 @@ Cloudflare Queues is integrated with [Cloudflare Workers](/workers). To send and
1313

1414
A Worker that can send messages to a Queue is a producer Worker, while a Worker that can receive messages from a Queue is a consumer Worker. It is possible for the same Worker to be a producer and consumer, if desired.
1515

16-
In the future, we expect to support other APIs, such as HTTP endpoints to send or receive messages. To report bugs or request features, go to the [Cloudflare Community Forums](https://community.cloudflare.com/c/developers/workers/40). To give feedback, go to the [`#queues-beta`](https://discord.cloudflare.com) Discord channel.
16+
In the future, we expect to support other APIs, such as HTTP endpoints to send or receive messages. To report bugs or request features, go to the [Cloudflare Community Forums](https://community.cloudflare.com/c/developers/workers/40). To give feedback, go to the [`#queues`](https://discord.cloudflare.com) Discord channel.
1717

1818
## Producer
1919

src/content/docs/queues/get-started.mdx

Lines changed: 5 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -18,11 +18,7 @@ To use Queues, you will need:
1818

1919
<Render file="prereqs" product="workers" />
2020

21-
## 1. Enable Queues
22-
23-
<Render file="enable-queues" />
24-
25-
## 2. Create a Worker project
21+
## 1. Create a Worker project
2622

2723
You will access your queue from a Worker, the producer Worker. You must create at least one producer Worker to publish messages onto your queue.
2824

@@ -52,7 +48,7 @@ Move into the newly created directory:
5248
cd producer-worker
5349
```
5450

55-
## 3. Create a queue
51+
## 2. Create a queue
5652

5753
To use queues, you need to create at least one queue to publish messages to and consume messages from.
5854

@@ -68,7 +64,7 @@ Queue names must be 1 to 63 characters long. Queue names cannot contain special
6864

6965
You cannot change your queue name after you have set it. After you create your queue, you will set up your producer Worker to access it.
7066

71-
## 4. Set up your producer worker
67+
## 3. Set up your producer Worker
7268

7369
To expose your queue to the code inside your Worker, you need to connect your queue to your Worker by creating a binding. [Bindings](/workers/runtime-apis/bindings/) allow your Worker to access resources, such as Queues, on the Cloudflare developer platform.
7470

@@ -140,7 +136,7 @@ Copy your `*.workers.dev` subdomain and paste it into a new browser tab. Refresh
140136

141137
You have built a queue and a producer Worker to publish messages to the queue. You will now create a consumer Worker to consume the messages published to your queue. Without a consumer Worker, the messages will stay on the queue until they expire, which defaults to four (4) days.
142138

143-
## 5. Create your consumer Worker
139+
## 4. Create your consumer Worker
144140

145141
A consumer Worker receives messages from your queue. When the consumer Worker receives your queue's messages, it can write them to another source, such as a logging console or storage objects.
146142

@@ -213,7 +209,7 @@ With your `wrangler.toml` file and `index.ts` file configured, publish your cons
213209
npx wrangler deploy
214210
```
215211

216-
## 6. Read messages from your queue
212+
## 5. Read messages from your queue
217213

218214
After you set up consumer Worker, you can read messages from the queue.
219215

src/content/docs/queues/index.mdx

Lines changed: 1 addition & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -4,8 +4,6 @@ type: overview
44
pcx_content_type: overview
55
sidebar:
66
order: 1
7-
badge:
8-
text: Beta
97
head:
108
- tag: title
119
content: Cloudflare Queues
@@ -24,15 +22,7 @@ Send and receive messages with guaranteed delivery and no charges for egress ban
2422

2523
<Plan type="paid" />
2624

27-
:::note
28-
29-
30-
[Cloudflare Queues is now in open Beta](https://blog.cloudflare.com/cloudflare-queues-open-beta/). Join the [`#queues-beta`](https://discord.cloudflare.com) channel in our Developer Discord to learn more.
31-
32-
33-
:::
34-
35-
Cloudflare Queues integrates with [Cloudflare Workers](/workers/) and enables you to build applications that can [guarantee delivery](/queues/reference/delivery-guarantees/), [offload work from a request](/queues/reference/how-queues-works/), [send data from Worker to Worker](/queues/configuration/configure-queues/), and [buffer or batch data](/queues/configuration/batching-retries/).
25+
Cloudflare Queues integrate with [Cloudflare Workers](/workers/) and enable you to build applications that can [guarantee delivery](/queues/reference/delivery-guarantees/), [offload work from a request](/queues/reference/how-queues-works/), [send data from Worker to Worker](/queues/configuration/configure-queues/), and [buffer or batch data](/queues/configuration/batching-retries/).
3626

3727
***
3828

src/content/docs/queues/platform/limits.mdx

Lines changed: 12 additions & 25 deletions
Original file line numberDiff line numberDiff line change
@@ -8,48 +8,35 @@ sidebar:
88

99
import { Render } from "~/components"
1010

11-
:::note
12-
13-
14-
Many of these limits will increase during Queues' public beta period. [Follow our changelog](/queues/platform/changelog/) or join the [`#queues-beta`](https://discord.cloudflare.com) channel in our Developer Discord to keep up-to-date with changes.
15-
16-
17-
:::
18-
19-
2011

2112
| Feature | Limit |
2213
| --------------------------------------------- | ------------------------------------------------------------- |
23-
| Queues | 10,000 per account <sup>beta</sup> |
14+
| Queues | 10,000 per account |
2415
| Message size | 128 KB <sup>1</sup> |
2516
| Message retries | 100 |
26-
| Maximum consumer batch size | 100 messages <sup>beta</sup> |
17+
| Maximum consumer batch size | 100 messages |
2718
| Maximum messages per `sendBatch` call | 100 (or 256KB in total) |
28-
| Maximum batch wait time | 60 seconds |
29-
| Per-queue message throughput <sup>2</sup> | 400 messages per second <sup>3</sup> |
30-
| Message retention period <sup>4</sup> | 4 days (96 hours) |
31-
| Per-queue backlog size <sup>5</sup> | 25GB |
32-
| Concurrent consumer invocations | 20 <sup>push-based only</sup> |
33-
| Consumer duration (wall clock time) | 15 minutes <sup>6</sup> |
19+
| Maximum Batch wait time | 60 seconds |
20+
| Per-queue message throughput | 5,000 messages per second <sup>2</sup> |
21+
| Message retention period <sup>3</sup> | 4 days (96 hours) |
22+
| Per-queue backlog size <sup>4</sup> | 25GB |
23+
| Concurrent consumer invocations | 250 <sup>push-based only</sup> |
24+
| Consumer duration (wall clock time) | 15 minutes <sup>5</sup> |
3425
| Consumer CPU time | 30 seconds |
3526
| `visibilityTimeout` (pull-based queues) | 12 hours |
3627
| `delaySeconds` (when sending or retrying) | 12 hours |
3728
| Requests to the Queues API (incl. pulls/acks) | [1200 requests / 5 mins](/fundamentals/api/reference/limits/) |
3829

3930

4031

41-
<sup>beta</sup> This limit is beta only and is expected to increase over time.
42-
4332
<sup>1</sup> 1 KB is measured as 1000 bytes. Messages can include up to \~100 bytes of internal metadata that counts towards total message limits.
4433

45-
<sup>2</sup> The maximum message throughput per queue will continue to increase during the beta period.
46-
47-
<sup>3</sup> Exceeding the maximum message throughput will cause the `send()` and `sendBatch()` methods to throw an exception with a `Too Many Requests` error until your producer falls below the limit.
34+
<sup>2</sup> Exceeding the maximum message throughput will cause the `send()` and `sendBatch()` methods to throw an exception with a `Too Many Requests` error until your producer falls below the limit.
4835

49-
<sup>4</sup> Messages in a queue that reach the maximum message retention are deleted from the queue. Queues does not delete messages in the same queue that have not reached this limit.
36+
<sup>3</sup> Messages in a queue that reach the maximum message retention are deleted from the queue. Queues does not delete messages in the same queue that have not reached this limit.
5037

51-
<sup>5</sup> Individual queues that reach this limit will receive a `Storage Limit Exceeded` error when calling `send()` or `sendBatch()` on the queue.
38+
<sup>4</sup> Individual queues that reach this limit will receive a `Storage Limit Exceeded` error when calling `send()` or `sendBatch()` on the queue.
5239

53-
<sup>6</sup> Refer to [Workers limits](/workers/platform/limits/#cpu-time).
40+
<sup>5</sup> Refer to [Workers limits](/workers/platform/limits/#cpu-time).
5441

5542
<Render file="limits_increase" product="workers" />

src/content/docs/queues/tutorials/web-crawler-with-browser-rendering/index.mdx

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -31,12 +31,6 @@ You can use Puppeteer to request all images on a page, save the colors used on a
3131

3232
<Render file="prereqs" product="workers" />
3333

34-
### Queues access
35-
36-
Additionally, you will need access to Queues.
37-
38-
<Render file="enable-queues" />
39-
4034
## 1. Create new Workers application
4135

4236
To get started, create a Worker application using the [`create-cloudflare` CLI](https://github.com/cloudflare/workers-sdk/tree/main/packages/create-cloudflare). Open a terminal window and run the following command:

src/content/docs/workers/platform/betas.mdx

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -18,5 +18,4 @@ These are the current alphas and betas relevant to the Cloudflare Workers platfo
1818
| Email Workers | || [Docs](/email-routing/email-workers/) |
1919
| Green Compute | || [Blog](https://blog.cloudflare.com/earth-day-2022-green-compute-open-beta/) |
2020
| Pub/Sub || | [Docs](/pub-sub) |
21-
| Queues | || [Docs](/queues) |
2221
| [TCP Sockets](/workers/runtime-apis/tcp-sockets/) | || [Docs](/workers/runtime-apis/tcp-sockets) |

src/content/partials/queues/enable-queues.mdx

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -3,12 +3,12 @@
33

44
---
55

6-
Queues is currently in [Public Beta](https://blog.cloudflare.com/cloudflare-queues-open-beta/) and is included in the monthly subscription cost of your Workers Paid plan, and charges based on operations against your queues. Refer to [Pricing](/queues/platform/pricing/) for more details.
6+
Queues are included in the monthly subscription cost of your Workers Paid plan, and charges based on operations against your queues. Refer to [Pricing](/queues/platform/pricing/) for more details.
77

88
Before you can use Queues, you must enable it via [the Cloudflare dashboard](https://dash.cloudflare.com/?to=/:account/workers/queues). You need a Workers Paid plan to enable Queues.
99

1010
To enable Queues:
1111

1212
1. Log in to the [Cloudflare dashboard](https://dash.cloudflare.com).
1313
2. Go to **Workers & Pages** > **Queues**.
14-
3. Select **Enable Queues Beta**.
14+
3. Select **Enable Queues**.

0 commit comments

Comments
 (0)