saltstack/salt
1
0
Fork 0
mirror of https://github.com/saltstack/salt.git synced 2025-04-17 10:10:20 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 2

decode_reponses=True on all Redis API interfaces

Browse source
This commit is contained in:
Ronald van Zantvoort 2018-08-19 00:11:20 +02:00
parent 1d843d4526
commit bdaef3907a
No known key found for this signature in database
GPG key ID: D3DE53B7EFF75061
5 changed files with 8 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
salt/cache/redis_cache.py vendored
View file

@ -238,7 +238,8 @@ def _get_redis_server(opts=None):
opts['port'],
unix_socket_path=opts['unix_socket_path'],
db=opts['db'],
password=opts['password'])
password=opts['password'],
decode_responses=True)
return REDIS_SERVER

2
salt/engines/redis_sentinel.py
View file

@ -63,7 +63,7 @@ class Listener(object):
tag = 'salt/engine/redis_sentinel'
super(Listener, self).__init__()
self.tag = tag
self.redis = redis.StrictRedis(host=host, port=port)
self.redis = redis.StrictRedis(host=host, port=port, decode_responses=True)
self.pubsub = self.redis.pubsub()
self.pubsub.psubscribe(channels)
self.fire_master = salt.utils.event.get_master_event(__opts__, __opts__['sock_dir']).fire_event

4
salt/modules/redismod.py
View file

@ -55,7 +55,7 @@ def _connect(host=None, port=None, db=None, password=None):
if not password:
password = __salt__['config.option']('redis.password')
return redis.StrictRedis(host, port, db, password)
return redis.StrictRedis(host, port, db, password, decode_responses=True)
def _sconnect(host=None, port=None, password=None):
@ -69,7 +69,7 @@ def _sconnect(host=None, port=None, password=None):
if password is None:
password = __salt__['config.option']('redis_sentinel.password')
return redis.StrictRedis(host, port, password=password)
return redis.StrictRedis(host, port, password=password, decode_responses=True)
def bgrewriteaof(host=None, port=None, db=None, password=None):

3
salt/returners/redis_return.py
View file

@ -188,7 +188,8 @@ def _get_serv(ret=None):
REDIS_POOL = redis.StrictRedis(host=_options.get('host'),
port=_options.get('port'),
unix_socket_path=_options.get('unix_socket_path', None),
db=_options.get('db'))
db=_options.get('db'),
decode_responses=True)
return REDIS_POOL

2
salt/tokens/rediscluster.py
View file

@ -53,7 +53,7 @@ def _redis_client(opts):
redis_host = opts.get("eauth_redis_host", "localhost")
redis_port = opts.get("eauth_redis_port", 6379)
try:
return rediscluster.StrictRedisCluster(host=redis_host, port=redis_port)
return rediscluster.StrictRedisCluster(host=redis_host, port=redis_port, decode_responses=True)
except rediscluster.exceptions.RedisClusterException as err:
log.warning(
'Failed to connect to redis at %s:%s - %s',