Connect to redis secure (rediss://)

[ono24id]

How to connect to redis secure (rediss://) ?

[geofmureithi]

Hey, assuming you are using 0.7.3, you should look at:
https://github.com/geofmureithi/apalis/blob/2a40166233a70d33adcd418f20559b0bcd754e4e/packages/apalis-redis/src/storage.rs#L31-L35.

The only thing you may need to add is the tls feature eg:

redis = { version = "*", features = [
    "tokio-rustls-comp"
] }

apalis itself doesnt bother with this, it just accepts a ready connection. You basically need to create the connection you want with the redis crate and then pass it to RedisStorage. Let me know if that helps.

See also:

• https://docs.rs/redis/latest/redis/#tls--ssl

[ono24id]

@geofmureithi thanks for quick response

That flag already implemented but still not work
redis = { version = "0.29", features = ["tokio-rustls-comp"] }

I tried another way by following deadpool_redis example, but the problem is I can not pass the storage to my axum app_state (it said connection not clone able)
https://github.com/geofmureithi/apalis/blob/main/examples/redis-deadpool/src/main.rs

any suggestion?

[geofmureithi]

That flag already implemented but still not work

What did not work specifically?

I recommend trying the redis + apalis without the other parts.
If you are still having problems please share a small reproducible example.

Regarding axum see: https://github.com/geofmureithi/apalis/blob/main/examples/axum/src/main.rs maybe you are looking for extension.

[geofmureithi]

You might be having problems with deadpool coz it is missing some constraints such as Connection not being Clone yet axum state needs Clone

[ono24id]

Cargo.toml

[dependencies]
axum = { version = "0.8.4", features = ["ws"] }
axum-extra = { version = "0.10.1", features = ["typed-header"] }
headers = "0.4"
tokio = { version = "1", features = ["full"] }

deadpool-redis = { version = "0.20" }
redis = { version = "0.29", features = ["tokio-rustls-comp"] }
apalis = { version = "0.7.3", features = ["retry", "limit"] }
apalis-redis = "0.7.3"

let redis_url = "rediss://default:A@singular-crappie-XXXX.upstash.io:6379".to_string();
// Apalis storage for background jobs
let apalis_conn = apalis_redis::connect(redis_url.clone()).await.expect("Failed to connect to Redis");
let queue_webhook_lpr = apalis_redis::RedisStorage::new(apalis_conn);

Error log

Failed to connect to Redis: can't connect with TLS, the feature is not enabled- InvalidClientConfig
note: run with `RUST_BACKTRACE=1` environment variable to display a backtrace

[geofmureithi]

The default provided function does not support tls. You need to:

1. Include tls support: https://docs.rs/redis/latest/redis/#tls--ssl
2. Use the build_with_tls method instead of apalis_redis::connect

[ono24id]

I think I found the root cause

├── apalis-redis v0.7.3
           ├── redis v0.32.7
├── deadpool-redis v0.20.0
          └── redis v0.29.5
├── redis v0.29.5 (*)

Solved by upgraded redis (v.32) and deadpool_redis (v0.22) to latest version, then apalis will use redis with tls feature same with other