django/daphne
1
1
Fork 0
mirror of https://github.com/django/daphne.git synced 2025-07-14 09:52:17 +03:00
Code Issues Packages Projects Releases Wiki Activity

Fixed #39: Allow redis:// URL redis configuration

Browse Source
This commit is contained in:
Bastian Hoyer 2015-12-16 20:42:56 +01:00
parent a6073157f4
commit 70bc429d0b
1 changed files with 7 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
channels/backends/redis_py.py
View File

@ -22,10 +22,12 @@ class RedisChannelBackend(BaseChannelBackend):
# Make sure they provided some hosts, or provide a default # Make sure they provided some hosts, or provide a default
if not hosts: if not hosts:
hosts = [("localhost", 6379)] hosts = [("localhost", 6379)]
for host, port in hosts: self.hosts = []
assert isinstance(host, six.string_types) for entry in hosts:
assert int(port) if isinstance(entry, six.string_types):
self.hosts = hosts self.hosts.append(entry)
else:
self.hosts.append("redis://%s:%d/0" % (entry[0],entry[1]))
self.prefix = prefix self.prefix = prefix
# Precalculate some values for ring selection # Precalculate some values for ring selection
self.ring_size = len(self.hosts) self.ring_size = len(self.hosts)
@ -57,8 +59,7 @@ class RedisChannelBackend(BaseChannelBackend):
# Catch bad indexes # Catch bad indexes
if not (0 <= index < self.ring_size): if not (0 <= index < self.ring_size):
raise ValueError("There are only %s hosts - you asked for %s!" % (self.ring_size, index)) raise ValueError("There are only %s hosts - you asked for %s!" % (self.ring_size, index))
host, port = self.hosts[index] return redis.Redis.from_url(self.hosts[index])
return redis.Redis(host=host, port=port)
def send(self, channel, message): def send(self, channel, message):
# if channel is no str (=> bytes) convert it # if channel is no str (=> bytes) convert it