INTEGRITY Документация

← Cloudflare Workflows / workflows / build

Вызов Workflows из Pages

Вы можете привязывать и запускать Workflows из Pages Functions путём развёртывания проекта Workers с определением вашего Workflow, а затем вызова этого Worker с помощью привязки к сервисам или стандартный fetch() вызов.

Использование Service Bindings

Service Bindings позволяют вызывать один Worker из другого Worker или из Pages Function без необходимости открывать к нему прямой доступ.

Для этого вам нужно:

  1. Разверните свой Workflow в Worker
  2. Создайте Service Binding к этому Worker в своём проекте Pages
  3. Вызовите Worker удаленно с помощью привязки

Например, если у вас есть Worker с именем workflows-starter, создайте новую привязку Service Binding в проекте Pages, как показано ниже, убедившись, что service имя совпадает с именем Worker, в котором определён ваш Workflow:

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

Ваш Worker может предоставлять определённый метод (или методы), которые смогут вызывать только другие Workers или Pages Functions через Service Binding.

В следующем примере мы предоставляем доступ к определённому createInstance метод, который принимает наш Payload и возвращает InstanceStatus из Workflows API:

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(),
		});
	}
}

Ваша Pages Function будет выглядеть примерно так:

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);
};

Подробнее о привязке ресурсов в Pages Functions, включая привязку через Cloudflare dashboard, см. в документацию по привязкам для Pages Functions.

Использование fetch

Вместо настройки Service Binding можно вызвать Worker по HTTP с помощью Workflows API Workers к create новый экземпляр Workflow для каждого входящего HTTP-вызова к 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(),
		});
	},
};

Ваш Pages Function затем может выполнить обычный fetch вызов к Worker:

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);
};

Также вы можете аутентифицировать такие запросы, передавая общий секрет в заголовке и проверяя его в своём Worker.

Следующие шаги