1 个不稳定版本
0.1.0 | 2023年3月23日 |
---|
#1401 in 数据库接口
15KB
252 行
postgres_queue
一个用于管理和执行PostgreSQL后端队列任务的库。
该库提供了一种简单的方法,使用PostgreSQL数据库作为任务队列,以并发和容错的方式定义、入队和执行任务。
特性
- 定义和注册任务处理器
- 使用可选的调度和间隔入队任务
- 具有可调整工作进程数量的并发任务处理
- 具有错误处理的容错任务执行
用法
将此添加到您的 Cargo.toml
[dependencies]
postgres_queue = "0.1.0"
示例
以下是一个基本示例,演示了如何使用postgres_queue
crate
use postgres_queue::{TaskRegistry, TaskData, TaskError, connect, initialize_database};
use chrono::{Utc, Duration};
#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
let database_url = "postgres://user:password@localhost/dbname";
let pool = connect(database_url).await?;
initialize_database(&pool).await?;
let mut task_registry = TaskRegistry::new();
task_registry.register_task("my_task", my_task_handler);
let task_data = serde_json::json!({ "message": "Hello, world!" });
let run_at = Utc::now() + Duration::seconds(10);
let task_id = postgres_queue::enqueue(&pool, "my_task", task_data.clone(), run_at, None).await?;
task_registry.run(&pool, 4).await?;
Ok(())
}
async fn my_task_handler(task_id: i32, task_data: TaskData) -> Result<(), TaskError> {
println!("Task {}: {:?}", task_id, task_data);
Ok(())
}
许可证
本项目采用MIT许可证。
依赖关系
~9–19MB
~275K SLoC