Python django.conf.settings 模块，REDIS_HOST 实例源码

def get_redis_connection():
    return redis.StrictRedis(
        host=settings.REDIS_HOST, port=settings.REDIS_PORT, db=settings.REDIS_DB, password=settings.REDIS_PASSWORD,
    )

def handle(self, *args, **options):
        if not options['coordinator-private-ip']:
            raise CommandError('Coordinator IP needs to be an IP address')

        coord_ip = options['coordinator-private-ip'].strip()

        redis_con = redis.StrictRedis(host=settings.REDIS_HOST,
                                      port=settings.REDIS_PORT,
                                      db=settings.REDIS_DB)
        redis_con.set('KAFKA_HOST',
                      '%s:9092' % coord_ip)
        redis_con.set('COORDINATOR_ENDPOINT',
                      'http://%s:8000/coordinator/' % coord_ip)

def in_known_cidr_block(ip_address):
    redis_con = redis.StrictRedis(host=settings.REDIS_HOST,
                                  port=settings.REDIS_PORT,
                                  db=settings.REDIS_DB)
    cidrs = redis_con.get('cidrs')

    if not cidrs or not len(cidrs):
        return False

    return len(netaddr.all_matching_cidrs(ip_address, cidrs.split(','))) > 0

def save_to_redis(cidrs):
    try:
        redis_con = redis.StrictRedis(host=settings.REDIS_HOST,
                                      port=settings.REDIS_PORT,
                                      db=settings.REDIS_DB)
        redis_con.set('cidrs', ','.join(list(cidrs)))
    except Exception as exc:
        print exc

def get_config(item_name):
    try:
        redis_con = redis.StrictRedis(host=settings.REDIS_HOST,
                                      port=settings.REDIS_PORT,
                                      db=settings.REDIS_DB)
        value = redis_con.get(item_name)
    except Exception as exc:
        print exc
        return None

    if value and len(value):
        return value

    return None

def __init__(self, host=settings.REDIS_HOST, port=settings.REDIS_PORT):
        self.host = host
        self.port = port
        self.redis_db = self.open_connection()

def __init__(self, verbose=False):
        self.r = redis.StrictRedis(host=settings.REDIS_HOST, port=settings.REDIS_PORT, db=0)
        self.verbose = verbose

def __init__(self):
        self.r = redis.StrictRedis(host=settings.REDIS_HOST, port=settings.REDIS_PORT, db=0)

def generate_token_for_user(uid):
    token = hashlib.md5(str(int(time.time() * 1000) + random.randint(10000000, 99999999))).hexdigest()
    r = redis.Redis(host=settings.REDIS_HOST, db=settings.REDIS_USER_TOKEN_DB)
    r.set(uid, token)
    return token

#test

def getToken(request):
    uid = request.GET.get('uid')
    r = redis.Redis(host=settings.REDIS_HOST, db=settings.REDIS_USER_TOKEN_DB)
    token = r.get(uid)
    if token is not None:
        return HttpResponse(token)
    else:
        return HttpResponse(u'????token,?token???')

def __init__(self, **kwargs):
        host = settings.REDIS_HOST
        port = int(settings.REDIS_PORT)
        password = settings.REDIS_PASSWORD
        redis.Redis.__init__(self, host=host, port=port, password=password)