连接dcs集群实例-j9九游会登录

from redis.cluster import rediscluster as redis
from redis.cluster import clusternode
redis_client = none
def create_redis_client(context):
    logger = context.getlogger()
    redis_cluster_nodes = context.getuserdata(
        "redis_ip_address")
    redis_password = context.getuserdata(
        "redis_password")
    startup_nodes = []
    for redis_node in redis_cluster_nodes.split(','):
        node_info = redis_node.split(":")
        startup_nodes.append(clusternode(host=node_info[0], port=node_info[1]))
    logger.info("redis startup_nodes={}".format(startup_nodes))
    client = redis(startup_nodes=startup_nodes,
                   password=redis_password,
                   cluster_error_retry_attempts=3,
                   socket_timeout=2,
                   socket_connect_timeout=2,
                   health_check_interval=60, max_connections=50,
                   decode_responses=true)
    return client
def initializer(context):
    global redis_client
    redis_client = create_redis_client(context)
    redis_client.ping()
def handler(event, context):
    logger = context.getlogger()
    redis_client.set('foo', 'bar')
    value = redis_client.get('foo')
    logger.info("redis get key foo value={}".format(value))
    return value

其他参数配置可以参考表3。