← Cloudflare Workers / workers / runtime-apis / handlers

Обработчик scheduled

Когда Worker вызывается через Cron Trigger, scheduled() обработчик обрабатывает вызов.

export default {
	async scheduled(controller, env, ctx) {
		await doSomeTaskOnASchedule();
	},
};

interface Env {}
export default {
	async scheduled(
		controller: ScheduledController,
		env: Env,
		ctx: ExecutionContext,
	) {
		await doSomeTaskOnASchedule();
	},
};

from workers import WorkerEntrypoint

class Default(WorkerEntrypoint):
    async def scheduled(self, controller, env, ctx):
        # controller.cron contains the cron pattern that triggered this event
        # controller.scheduledTime contains the scheduled time in ms since epoch
        print(f"Cron triggered: {controller.cron}")

• controller.cron строка

  • Значение Cron Trigger который запустил ScheduledEvent.

• controller.type строка

  • Тип контроллера. Всегда возвращает "scheduled".

• controller.scheduledTime число

  • Время, когда ScheduledEvent был запланирован к выполнению в миллисекундах с 1 января 1970 года по UTC. Это значение можно разобрать как new Date(controller.scheduledTime).

• env объект

  • Объект, содержащий привязки, связанные с вашим Worker при использовании формата ES-модулей, такие как пространства имён KV и Durable Objects.

• ctx объект

  • Объект, содержащий контекст, связанный с вашим Worker при использовании формата ES-модулей. В настоящее время этот объект содержит только waitUntil функцию.

Когда вы настраиваете несколько Cron Triggers для одного Worker каждый триггер вызывает один и тот же scheduled() обработчик. Используйте controller.cron чтобы определить, какое расписание сработало, и выполнить для каждого свою логику.

{
	"triggers": {
		"crons": ["*/5 * * * *", "0 0 * * *"],
	},
}

[triggers]
crons = [ "*/5 * * * *", "0 0 * * *" ]

export default {
	async scheduled(controller, env, ctx) {
		switch (controller.cron) {
			case "*/5 * * * *":
				await fetch("https://example.com/api/sync");
				break;
			case "0 0 * * *":
				await env.MY_KV.put("last-cleanup", new Date().toISOString());
				break;
		}
	},
};

export default {
	async scheduled(
		controller: ScheduledController,
		env: Env,
		ctx: ExecutionContext,
	) {
		switch (controller.cron) {
			case "*/5 * * * *":
				await fetch("https://example.com/api/sync");
				break;
			case "0 0 * * *":
				await env.MY_KV.put("last-cleanup", new Date().toISOString());
				break;
		}
	},
} satisfies ExportedHandler<Env>;

from workers import WorkerEntrypoint, fetch
from datetime import datetime, timezone

class Default(WorkerEntrypoint):
    async def scheduled(self, controller, env, ctx):
        if controller.cron == "*/5 * * * *":
            await fetch("https://example.com/api/sync")
        elif controller.cron == "0 0 * * *":
            await env.MY_KV.put("last-cleanup", datetime.now(timezone.utc).isoformat())

Значение controller.cron это точная строка cron-выражения из вашей конфигурации. Она должна совпадать посимвольно, включая пробелы.

Когда скрипт Workers вызывается Cron Trigger, среда выполнения Workers запускает ScheduledEvent который будет обработан scheduled функция в классе Workers Module. ctx аргумент представляет контекст, в котором выполняется ваша функция, и содержит следующие методы для управления дальнейшим поведением:

• ctx.waitUntil(promise) : void. Используйте этот метод для регистрации асинхронных задач (например, логирования, аналитики для сторонних сервисов, потоковой передачи данных и кеширования), которые должны завершиться до завершения вызова. Первый ctx.waitUntil завершиться ошибкой будут отслеживаться и фиксироваться как статус в Cron Trigger таблице Past Events. В противном случае это будет зафиксировано как успешное выполнение.