redis auth

main.py

@@ -12,10 +12,10 @@ import settings
 
 class Monitor(object):
     def __init__(self):
-        self.rs = {redis_url: redis.StrictRedis(*redis_url.split(':')) for redis_url in settings.REDIS_URL}
+        self.rs = {"{}:{}/{}".format(r['host'], r['port'], r['db']): redis.StrictRedis(**r) for r in settings.REDIS}
         self.keyprefix_queue = '_kombu.binding.'
         self.sep = '\x06\x16'
-        self.redis_queue_map = {redis_url: [] for redis_url in settings.REDIS_URL}
+        self.redis_queue_map = {"{}:{}/{}".format(r['host'], r['port'], r['db']): [] for r in settings.REDIS}
 
     def refresh_redis_queue_map(self):
         for url, r in self.rs.items():

settings.py

@@ -3,8 +3,8 @@
 """
 
 # redis URL
-REDIS_URL = [
-    'localhost',
+REDIS = [
+    {'host':'localhost', 'port': 6379, 'db': 2, 'password':'secret'},
 ]
 
 # pushgateway URL