Python redis-py 示例
Python redis-py 示例
import redis
r = redis.Redis()
pipe = r.pipeline(transaction=False) # True 则自动包 MULTI/EXEC
for i in range(10000):
pipe.set(f'k:{i}', i, ex=3600)
results = pipe.execute() # 一次网络往返全部完成redis-cli 批量导入
redis-cli 批量导入
printf 'SET k1 v1\nSET k2 v2\n' > cmds.txt
redis-cli --pipe < cmds.txt # 高速批量导入(返回 errors 数要盯)| 收益 | RTT 从 N 次降为 1 次;吞吐数倍提升 |
|---|---|
| 单批大小 | 几百到几千条 / 约 1MB 内一批较稳 |
| 错误定位 | execute() 返回逐条结果,需自己检查异常项 |
超大 pipeline 会长时间占用服务端单线程并撑大客户端内存;分批发(如每批 500-1000 条)。