INTEGRITY Dokumentace

← Cloudflare Workflows / workflows / build

Volání Workflows z Pages

Workflows můžete navázat a spouštět z Pages Functions nasazením projektu Workers s definicí vašeho Workflow a následným voláním daného Workeru pomocí service bindings nebo standardní fetch() volání.

Použijte Service Bindings

Service Bindings umožňují vám volat Worker z jiného Workeru nebo z Pages Function, aniž byste ho museli přímo vystavit.

Abyste to provedli, budete muset:

  1. Nasaďte svůj Workflow ve Workeru
  2. Vytvořte Service Binding k tomuto Workeru ve vašem projektu Pages
  3. Zavolejte Worker vzdáleně pomocí bindingu

Pokud máte například Worker s názvem workflows-starter, vytvořili byste v projektu Pages novou Service Binding následujícím způsobem a zajistili, že service odpovídá názvu Worker, ve kterém je váš Workflow definován:

{
	"services": [
		{
			"binding": "WORKFLOW_SERVICE",
			"service": "workflows-starter"
		}
	]
}
[[services]]
binding = "WORKFLOW_SERVICE"
service = "workflows-starter"

Váš Worker může zpřístupnit konkrétní metodu (nebo metody), kterou mohou přes Service Binding volat pouze jiné Workers nebo Pages Functions.

V následujícím příkladu zpřístupníme konkrétní createInstance metoda, která přijímá náš Payload a vrací InstanceStatus z API Workflows:

index.js
import { WorkerEntrypoint } from "cloudflare:workers";

export default class WorkflowsService extends WorkerEntrypoint {
	// Currently, entrypoints without a named handler are not supported
	async fetch() {
		return new Response(null, { status: 404 });
	}

	async createInstance(payload) {
		let instance = await this.env.MY_WORKFLOW.create({
			params: payload,
		});

		return Response.json({
			id: instance.id,
			details: await instance.status(),
		});
	}
}
index.ts
import { WorkerEntrypoint } from "cloudflare:workers";

interface Env {
	MY_WORKFLOW: Workflow;
}

type Payload = {
	hello: string;
};

export default class WorkflowsService extends WorkerEntrypoint<Env> {
	// Currently, entrypoints without a named handler are not supported
	async fetch() {
		return new Response(null, { status: 404 });
	}

	async createInstance(payload: Payload) {
		let instance = await this.env.MY_WORKFLOW.create({
			params: payload,
		});

		return Response.json({
			id: instance.id,
			details: await instance.status(),
		});
	}
}

Vaše Pages Function by pak mohla vypadat takto:

functions/request.js
export const onRequest = async (context) => {
	// This payload could be anything from within your app or from your frontend
	let payload = { hello: "world" };
	return context.env.WORKFLOWS_SERVICE.createInstance(payload);
};
functions/request.ts
interface Env {
	WORKFLOW_SERVICE: Service;
}

export const onRequest: PagesFunction<Env> = async (context) => {
	// This payload could be anything from within your app or from your frontend
	let payload = { hello: "world" };
	return context.env.WORKFLOWS_SERVICE.createInstance(payload);
};

Více informací o navazování na prostředky z Pages Functions, včetně navázání přes Cloudflare dashboard, najdete v dokumentace k vazbám pro Pages Functions.

Použití fetch

Alternativou k nastavení Service Binding je zavolat Worker přes HTTP pomocí Workflows Workers API na create novou instanci Workflow pro každé příchozí volání HTTP na Worker:

index.js
// This is in the same file as your Workflow definition
export default {
	async fetch(req, env) {
		let instance = await env.MY_WORKFLOW.create({
			params: payload,
		});
		return Response.json({
			id: instance.id,
			details: await instance.status(),
		});
	},
};
index.ts
// This is in the same file as your Workflow definition
export default {
	async fetch(req: Request, env: Env): Promise<Response> {
		let instance = await env.MY_WORKFLOW.create({
			params: payload,
		});
		return Response.json({
			id: instance.id,
			details: await instance.status(),
		});
	},
};

Váš Pages Function pak může provést běžné fetch volání Workeru:

functions/request.js
export const onRequest = async (context) => {
	// Other code
	let payload = { hello: "world" };
	const instanceStatus = await fetch("https://YOUR_WORKER.workers.dev/", {
		method: "POST",
		body: JSON.stringify(payload), // Send a payload for our Worker to pass to the Workflow
	});

	return Response.json(instanceStatus);
};
functions/request.ts
export const onRequest: PagesFunction<Env> = async (context) => {
	// Other code
	let payload = { hello: "world" };
	const instanceStatus = await fetch("https://YOUR_WORKER.workers.dev/", {
		method: "POST",
		body: JSON.stringify(payload), // Send a payload for our Worker to pass to the Workflow
	});

	return Response.json(instanceStatus);
};

Tyto požadavky můžete také ověřovat pomocí sdíleného tajného klíče předaného v hlavičce, který následně ověříte ve vašem Workeru.

Další kroky