srill 1.1.0

Subscribe Redis and Invoke Lambda with cargo lambda, for Local development.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15

pub fn subscribe<'a>(
    redis_url: &'a str,
    channel: &'a str,
    callback: impl Fn(&str) + Send + 'static,
) -> anyhow::Result<()> {
    let client = redis::Client::open(redis_url)?;
    let mut conn = client.get_connection()?;
    let mut pubsub = conn.as_pubsub();
    pubsub.subscribe(channel)?;

    loop {
        let msg: String = pubsub.get_message()?.get_payload()?;
        callback(&msg);
    }
}