Cron

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

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

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 表达式每个时间单位对应一个字段，并用空格分隔：

┌──────────── 分钟 (0-59)
│ ┌────────── 小时 (0-23)
│ │ ┌──────── 日期 (1-31)
│ │ │ ┌────── 月份 (1-12 或 JAN-DEC)
│ │ │ │ ┌──── 星期几 (0-6 或 SUN-SAT，其中 0 表示星期日)
│ │ │ │ │
* * * * *

每个字段都可以接受一个精确值、*（每个值）、一个范围（1-5）、一个列表（1,3,5）或一个步进值（*/15 表示每十五个单位一次）。例如， 0 9 * * MON-FRI 会在工作日的 UTC 09:00 运行。

计划可以是标准的 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 嵌套在其下。

定义一个 cron 任务 Jump to heading#

重试和退避 Jump to heading#

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

OpenTelemetry Jump to heading#

Did you find what you needed?

定义一个 cron 任务 Jump to heading

重试和退避 Jump to heading

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

OpenTelemetry Jump to heading