← Cloudflare Queues / queues / příklady

Publikování do fronty přes Workers

Následující příklad ukazuje, jak publikovat zprávy do fronty z Workeru. Worker v příkladu přijme JSON payload z těla požadavku a zapíše ho do fronty beze změny, ale ve skutečné aplikaci byste před zařazením zprávy do fronty pravděpodobně potřebovali další logiku.

Předpoklady

A fronta vytvořena prostřednictvím Cloudflare dashboard ↗ nebo wrangler CLI.
A nakonfigurováno producent binding v dashboardu Cloudflare nebo v souboru Wrangler.

Soubor Wrangler nakonfigurujte následovně:

{
	"$schema": "./node_modules/wrangler/config-schema.json",
	"name": "my-worker",
	"queues": {
		"producers": [
			{
				"queue": "my-queue",
				"binding": "YOUR_QUEUE"
			}
		]
	}
}

"$schema" = "./node_modules/wrangler/config-schema.json"
name = "my-worker"

[[queues.producers]]
queue = "my-queue"
binding = "YOUR_QUEUE"

1. Vytvořte Worker

Následující skript Workeru:

Ověří, že tělo požadavku je platný JSON.
Publikuje payload do fronty.

interface Env {
	YOUR_QUEUE: Queue;
}

export default {
	async fetch(req, env, ctx): Promise<Response> {
		// Validate the payload is JSON
		// In a production application, we may more robustly validate the payload
		// against a schema using a library like 'zod'
		let messages;
		try {
			messages = await req.json();
		} catch {
			// Return a HTTP 400 (Bad Request) if the payload isn't JSON
			return Response.json({ error: "payload not valid JSON" }, { status: 400 });
		}

		// Publish to the Queue
		try {
			await env.YOUR_QUEUE.send(messages);
		} catch (e) {
			const message = e instanceof Error ? e.message : "Unknown error";
			console.error(`failed to send to the queue: ${message}`);
			// Return a HTTP 500 (Internal Error) if our publish operation fails
			return Response.json({ error: message }, { status: 500 });
		}

		// Return a HTTP 200 if the send succeeded!
		return Response.json({ success: true });
	},
} satisfies ExportedHandler<Env>;

Jak nasadit tento Worker:

npx wrangler deploy

2. Odešlete testovací zprávu

Abyste se ujistili, že se zpráva do fronty úspěšně zapsala, použijte curl na příkazovém řádku:

# Make sure to replace the placeholder with your shared secret
curl -XPOST "https://YOUR_WORKER.YOUR_ACCOUNT.workers.dev" --data '{"messages": [{"msg":"hello world"}]}'

{"success":true}

Tímto se odešle požadavek HTTP POST a v případě úspěchu se vrátí HTTP 200 s success: true tělo odpovědi.

Pokud obdržíte HTTP 400, znamená to, že jste se pokusili do fronty odeslat poškozený JSON.
Pokud obdržíte HTTP 500, znamená to, že se zprávu nepodařilo úspěšně zapsat do fronty.

Můžete použít wrangler tail k odladění výstupu console.log.