def connect()

in lambda-feature-store/movie_recommendations/put_movie_recommendations.py [0:0]


def connect(redis_host_endpoint):
    startup_nodes = [{ "host": redis_host_endpoint, "port": "6379" }]
    redis_pool = rediscluster.ClusterConnectionPool(max_connections=5, startup_nodes=startup_nodes, skip_full_coverage_check=True, decode_responses=True)
    return redis_pool