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