1234567891011121314151617 |
- import time
- from redis import Redis, ConnectionError
- def connect_to_redis(host):
- time.sleep(2)
- print "Connecting to redis"
- while True:
- try:
- redis = Redis(host=host, db=0)
- redis.ping()
- print "Connected to redis"
- return redis
- except ConnectionError:
- print "Failed to connect to redis - retrying"
- time.sleep(1)
|