Cron 绑定规范

关于 cron 绑定组件的详细文档

组件格式

要设置 cron 绑定,需要创建一个类型为 bindings.cron 的组件。请参考本指南了解如何创建和应用绑定配置。

apiVersion: dapr.io/v1alpha1
kind: Component
metadata:
  name: <NAME>
spec:
  type: bindings.cron
  version: v1
  metadata:
  - name: schedule
    value: "@every 15m" # 有效的 cron 调度
  - name: direction
    value: "input"

规范元数据字段

字段必需绑定支持详情示例
scheduleY输入使用的有效 cron 调度。详见此处"@every 15m"
directionN输入绑定的方向"input"

调度格式

Dapr cron 绑定支持以下格式:

字符描述可接受的值
10 到 59,或 *
20 到 59,或 *
3小时0 到 23,或 * (UTC)
4月中的某天1 到 31,或 *
51 到 12,或 *
6星期几0 到 7 (其中 0 和 7 代表星期日),或 *

例如:

  • 30 * * * * * - 每 30 秒执行一次
  • 0 15 * * * * - 每 15 分钟执行一次
  • 0 30 3-6,20-23 * * * - 在凌晨 3 点到 6 点和晚上 8 点到 11 点之间,每小时的半点执行一次
  • CRON_TZ=America/New_York 0 30 04 * * * - 每天纽约时间凌晨 4:30 执行一次

您可以在这里了解更多关于 cron 和支持的格式。

为了便于使用,Dapr cron 绑定还支持一些快捷方式:

  • @every 15s 其中 s 是秒,m 是分钟,h 是小时
  • @daily@hourly 从绑定初始化时开始按该周期运行

监听 cron 绑定

设置 cron 绑定后,您只需监听与组件名称匹配的端点。假设 [NAME] 是 scheduled。这将作为一个 HTTP POST 请求。下面的示例展示了一个简单的 Node.js Express 应用程序如何在 /scheduled 端点接收调用并向控制台写入消息。

app.post('/scheduled', async function(req, res){
    console.log("scheduled endpoint called", req.body)
    res.status(200).send()
});

运行此代码时,请注意 /scheduled 端点每十五分钟由 Dapr sidecar 调用。

绑定支持

此组件支持输入绑定接口。

相关链接