import redis from redis.sentinel import Sentinel def get_redis_connection(sentinel_hosts, service_name): sentinel = Sentinel(sentinel_hosts, socket_timeout=0.1) master = sentinel.master_for(service_name, socket_timeout=0.1) slave = sentinel.slave_for(service_name, socket_timeout=0.1) return master, slave def main(): # Specify the Sentinel hosts and the Redis service name sentinel_hosts = [('127.0.1.1', 26379), ('127.0.1.1', 26380), ('127.0.1.1', 26381)] service_name = 'mymaster' # Get the Redis connections master, slave = get_redis_connection(sentinel_hosts, service_name) print(f" Master and slave : {master} {slave}") # Perform write operation on the master master.set('key1', 'hey') # Perform read operation on the slave value = slave.get('key1') print(f"Read from slave: {value}") if __name__ == "__main__": main()