Skip to content

Commit d149906

Browse files
authored
Add Redis SSL support. (#229)
* Add redis SSL support * Update requirements-base.txt * Update requirements-base.txt * Add SSL connectionclass * Some debugging * More debugging * Should work now
1 parent 623390d commit d149906

1 file changed

Lines changed: 6 additions & 1 deletion

File tree

mrq/context.py

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -139,9 +139,13 @@ def versiontuple(v):
139139
if isinstance(config_obj, basestring):
140140

141141
import redis as pyredis
142+
import redis.connection as pyredisconnection
142143

144+
connection_class = pyredisconnection.Connection
143145
urllib.parse.uses_netloc.append('redis')
144146
redis_url = urllib.parse.urlparse(config_obj)
147+
if redis_url.scheme == "rediss":
148+
connection_class = pyredisconnection.SSLConnection
145149

146150
log.info("%s: Connecting to Redis at %s..." %
147151
(attr, redis_url.hostname))
@@ -153,7 +157,8 @@ def versiontuple(v):
153157
password=redis_url.password if redis_url.password is not None else redis_url.username,
154158
max_connections=int(config.get("redis_max_connections")),
155159
timeout=int(config.get("redis_timeout")),
156-
decode_responses=False
160+
decode_responses=False,
161+
connection_class=connection_class
157162
)
158163
return pyredis.StrictRedis(connection_pool=redis_pool)
159164

0 commit comments

Comments
 (0)