Connect to a redis sentinel

redis_con.py

from redis.sentinel import Sentinel
def connect_to_redis(address: str, port: int, redis_set: str):
    sentinel = Sentinel([(address, port)], socket_timeout=0.5)
    con = sentinel.master_for(
        redis_set,
        decode_responses=True,
        socket_timeout=0.5,
    )
    con.echo("test")
    return con