def connect()

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


def connect(redis_host_endpoint):
    # If you are using different port number, please update here.
    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