Cron

Deno.cron() 是 Deno 的一个运行时 API，用于安排 JavaScript 或 TypeScript 代码按重复计划运行，计划使用 cron 语法 表示。它随 Deno 本身一起发布，因此在本地运行的相同代码无需修改即可部署。

Deno.cron 目前是一个不稳定的 API。要在本地使用 deno run，请启用 --unstable-cron 标志 （或将 "cron" 添加到 unstable 数组中， 位于 deno.json）。

deno run --unstable-cron main.ts

Deno.cron API 参考

定义一个 cron 任务 Jump to heading#

Deno.cron() 接受一个可读名称、一个计划， 以及一个处理函数。名称用于在日志中标识 cron 任务，计划 决定处理函数何时触发，所有时间均使用 UTC。

Deno.cron("log-a-message", "* * * * *", () => {
  console.log("这段代码每分钟运行一次。");
});

计划可以是标准的 5 字段 cron 表达式，也可以是结构化对象：

Deno.cron("hourly-task", { hour: { every: 1 } }, () => {
  console.log("这段代码每小时运行一次。");
});

cron 任务必须在模块顶层注册，并且要在任何服务器启动之前完成。 嵌套在请求处理器、条件语句或回调中的定义不会被识别。

重试和退避 Jump to heading#

默认情况下，失败的处理函数调用不会重试。传入 backoffSchedule （一个毫秒延迟数组）即可在失败时重试：

Deno.cron(
  "retry-example",
  "* * * * *",
  { backoffSchedule: [1000, 5000, 10000] },
  () => {
    throw new Error("最多会重试三次。");
  },
);

在生产环境中运行 cron 任务 Jump to heading#

Deno.cron 在 Deno CLI 中将执行状态保存在内存里，这意味着每个进程都会维护自己独立的一组 cron 任务。 对于生产工作负载，Deno Deploy 在此运行时 API 的基础上构建：它会在部署时发现你的 Deno.cron() 定义，负责调度和调用它们，处理重试，并在仪表板中展示运行情况——因此你无需自己维护一个长期运行的进程。

OpenTelemetry Jump to heading#

当启用 OpenTelemetry 时 （OTEL_DENO=true），每次 Deno.cron() 调用 都会自动生成一个 OpenTelemetry span。这使你能够将 cron 执行 与你的其他已埋点代码一起进行追踪：

OTEL_DENO=true deno run --unstable-cron main.ts

每次 cron 调用都会创建一个以该 cron 作业命名的 span。该 span 覆盖 处理函数的执行时长，且在处理函数内部创建的任何 span 都会作为子 span 嵌套在其下。