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
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