redis-py的pipeline.execute()返回全4数组是什么原因？如何处理？

问题1：pipeline.execute()返回全4数组是否代表执行过程出错？ #

不是。你已经配置了raise_on_error=True，如果pipeline中的任意命令执行出错，redis-py会直接抛出对应异常，不会正常返回结果数组，所以该返回值属于正常执行结果。

问题2：如果确实出错，该如何排查具体问题？ #

• 将返回数组的元素和你提交的hset命令一一对应，数组的第N个元素就是你提交的第N条hset命令的执行结果，你可以先打印每次hset传入的inner_dict的长度，确认是否和返回值匹配。
• 临时增加校验逻辑：每次执行execute后，随机抽取几个写入的key，调用hgetall或者hlen方法，校验实际存储的字段和你写入的内容是否一致。
• 查看Redis服务端的运行日志，服务端会记录内存不足、权限不足、命令语法错误等运行时异常，可通过日志确认是否有异常记录。

问题3：如果没有出错，该返回值的实际含义是什么？ #

pipeline.execute()返回的数组，每个元素严格对应你按顺序提交到pipeline的每条命令的执行结果。你提交的所有命令都是hset，Redis原生HSET命令的返回值规则为：返回本次操作成功新增的哈希字段数量。
如果写入的字段已经存在于对应哈希key中，本次操作仅更新字段值的话，不会被计入返回数；只有首次写入的新字段才会被计数。
你之前返回全0，说明你写入的所有哈希字段都是已经存在的，本次操作仅更新了值，没有新增任何字段；后续返回全4，说明你每次hset传入的inner_dict中，刚好有4个字段是对应哈希key中不存在的，本次操作成功新增了4个字段。

额外说明：你贴出的代码存在两处可修正的点

1. for k, inner_dict in dictionary.items()后面缺少英文冒号，会触发语法错误
2. 如果单个字典的元素量过大，单次pipeline提交的命令过多可能导致Redis阻塞，可根据实际业务情况调整单次pipeline的命令提交阈值

内容的提问来源于stack exchange，提问作者ciurlaro