14 个版本

0.3.0 2023 年 8 月 24 日
0.2.2 2023 年 7 月 10 日
0.2.0 2023 年 6 月 30 日
0.1.10 2023 年 3 月 15 日
0.1.2 2022 年 12 月 31 日

#19 in #flows

MIT/Apache

6KB
57

这是一个库,用于将您的流程函数作为 cron 作业在 flows.network 中进行调度。

有关详细信息,请参阅 调度集成


lib.rs:

Flows.network 中将流程函数作为计划任务执行

快速入门

要开始,让我们编写一个任务,每天在固定时间向 Slack 发送消息。

use schedule_flows::{schedule_cron_job, schedule_handler};
use slack_flows::send_message_to_channel;

#[no_mangle]
#[tokio::main(flavor = "current_thread")]
pub async fn on_deploy() {
    schedule_cron_job(String::from("50 8 * * *"), String::from("cron_job_evoked")).await;
}

#[schedule_handler]
async fn handler(body: Vec<u8>) {
    send_message_to_channel(
        "myworkspace",
        "mychannel",
        String::from_utf8_lossy(&body).into_owned(),
    ).await
}

[schedule_cron_job()] 将创建一个 cron 作业。使用宏 [schedule_handler] 装饰的 handler 会在每天 UTC 时间 8:50 被调用。

依赖项

~1–1.7MB
~41K SLoC