sss.py 文件源码

def pika_connection_create():
    import redis.connection
    try:
        pika_conn = redis.StrictRedis(
            host=host,
            port=port,
            password=password)
    except Exception,e:
        server.err = 1
        server.errmsg = get_exception_message(sys._getframe().f_code.co_name,sys._getframe().f_lineno, e)

    return pika_conn