我正在用python为redis集群编写cron脚本，并使用redis-py-cluster只从prod服务器读取数据。一个单独的java应用程序正在使用snappy压缩和java字符串编解码器utf-8编写redis集群。
我能读数据，但不能解码。

from rediscluster import RedisCluster
import snappy

host, port ="127.0.0.1", "30001"
startup_nodes = [{"host": host, "port": port}]
print("Trying connecting to redis cluster host=" + host +  ", port=" + str(port))

rc = RedisCluster(startup_nodes=startup_nodes, max_connections=32, decode_responses=True)
print("Connected",  rc)

print("Reading all keys, value ...\n\n")
for key in rc.scan_iter("uidx:*"):
   value = rc.get(key)
   #uncompress = snappy.uncompress(value, decoding="utf-8")
   print(key, value)
   print('\n')

print("Done. exit()")
exit()
``` `decode_responses=False` 对这个评论没问题。然而，变化 `decode_responses=True` 正在抛出错误。我的猜测是它不能得到正确的解码器。

Traceback (most recent call last):
File "splooks_cron.py", line 22, in
print(key, rc.get(key))
File "/Library/Python/2.7/site-packages/redis/client.py", line 1207, in get
return self.execute_command('GET', name)
File "/Library/Python/2.7/site-packages/rediscluster/utils.py", line 101, in inner
return func(*args,**kwargs)
File "/Library/Python/2.7/site-packages/rediscluster/client.py", line 410, in execute_command
return self.parse_response(r, command,**kwargs)
File "/Library/Python/2.7/site-packages/redis/client.py", line 768, in parse_response
response = connection.read_response()
File "/Library/Python/2.7/site-packages/redis/connection.py", line 636, in read_response
raise e
: 'utf8' codec can't decode byte 0x82 in position 0: invalid start byte

ps:取消对此行的注解 `uncompress = snappy.uncompress(value, decoding="utf-8")` 因为错误而中断

Traceback (most recent call last):
File "splooks_cron.py", line 27, in
uncompress = snappy.uncompress(value, decoding="utf-8")
File "/Library/Python/2.7/site-packages/snappy/snappy.py", line 91, in uncompress
return _uncompress(data).decode(decoding)
snappy.UncompressError: Error while decompressing: invalid input