@@ -42,6 +42,7 @@ def __init__(self,
42
42
load_lua_dependencies = True ,
43
43
blocking_timeout = 1000 ,
44
44
blocking_sleep_interval = 0.01 ,
45
+ decode_responses = False ,
45
46
** kwargs ):
46
47
"""
47
48
Initialize as either StrictRedis or Redis.
@@ -61,6 +62,7 @@ def __init__(self,
61
62
self .pubsub = defaultdict (list )
62
63
# Dictionary from script to sha ''Script''
63
64
self .shas = dict ()
65
+ self .decode_responses = decode_responses
64
66
65
67
@classmethod
66
68
def from_url (cls , url , db = None , ** kwargs ):
@@ -1543,7 +1545,9 @@ def _encode(self, value):
1543
1545
else :
1544
1546
value = value .encode ('utf-8' , 'strict' )
1545
1547
1546
- return value .decode ('utf-8' , 'strict' )
1548
+ if self .decode_responses :
1549
+ return value .decode ('utf-8' , 'strict' )
1550
+ return value
1547
1551
1548
1552
def _log (self , level , msg ):
1549
1553
pass
@@ -1559,7 +1563,8 @@ def mock_redis_client(**kwargs):
1559
1563
can return a MockRedis object
1560
1564
instead of a Redis object.
1561
1565
"""
1562
- return MockRedis ()
1566
+ return MockRedis (** kwargs )
1567
+
1563
1568
1564
1569
mock_redis_client .from_url = mock_redis_client
1565
1570
@@ -1570,6 +1575,7 @@ def mock_strict_redis_client(**kwargs):
1570
1575
can return a MockRedis object
1571
1576
instead of a StrictRedis object.
1572
1577
"""
1573
- return MockRedis (strict = True )
1578
+ return MockRedis (strict = True , ** kwargs )
1579
+
1574
1580
1575
1581
mock_strict_redis_client .from_url = mock_strict_redis_client
0 commit comments