Crate apalis_sql
source · [−]Expand description
Apalis Sql Storage
Apalis offeres Sqlite, Mysql and Postgres storages for its workers.
Example
ⓘ
#[tokio::main]
async fn main() -> std::io::Result<()> {
std::env::set_var("RUST_LOG", "debug,sqlx::query=error");
let database_url = std::env::var("DATABASE_URL").expect("Must specify url to db");
let pg: PostgresStorage<Email> = PostgresStorage::connect(database_url).await.unwrap();
async fn send_email(job: Email, _ctx: JobContext) -> Result<JobResult, JobError> {
log::info!("Attempting to send email to {}", job.to);
Ok(JobResult::Success)
}
Monitor::new()
.register_with_count(4, move |_| {
WorkerBuilder::new(pg.clone())
.build_fn(send_email)
})
.run()
.await
}