ability to use a Redis connection URI - closes #402

This commit is contained in:
valentinogagliardi
2020-01-12 13:13:41 +01:00
parent 70269e1e43
commit fa1082ff96
2 changed files with 8 additions and 0 deletions
+2
View File
@@ -59,4 +59,6 @@ class Redis(Broker):
def get_connection(list_key=Conf.PREFIX):
if django_redis and Conf.DJANGO_REDIS:
return django_redis.get_redis_connection(Conf.DJANGO_REDIS)
if isinstance(Conf.REDIS, str):
return redis.from_url(Conf.REDIS)
return redis.StrictRedis(**Conf.REDIS)