python客户端pipeline问题

[Kegann]

问题描述:
使用python客户端pipeline入库时报错,但数据却入进去了.

python程序:
import redis
r=redis.StrictRedis(host='10.40.0.70',port='9221')
pr=redis.pipeline()
pr.set('t1',1)
pr.set('t2',2)
pr.execute()

Traceback (most recent call last):
File "q5.py", line 7, in
pr.execute()
File "/usr/lib/python2.7/site-packages/redis/client.py", line 2879, in execute
return execute(conn, stack, raise_on_error)
File "/usr/lib/python2.7/site-packages/redis/client.py", line 2772, in execute_transaction
response = self.parse_response(connection, '')
File "/usr/lib/python2.7/site-packages/redis/client.py", line 2838, in parse_response
self, connection, command_name, **options)
File "/usr/lib/python2.7/site-packages/redis/client.py", line 680, in parse_response
response = connection.read_response()
File "/usr/lib/python2.7/site-packages/redis/connection.py", line 629, in read_response
raise response
redis.exceptions.ResponseError: Err unknown or unsupported command 'exec'

查看数据库，数据却入进去了.
10.40.0.70:9221> keys *

1. "t1"
2. "t2"

补充说明：
redis-py版本:2.10.5
测试了将
r=redis.StrictRedis(host='10.40.0.70',port='9221') 的ip 端口改成本地redis的ip 端口就不会报错,因此推断客户端没有问题,想请问是不是pika不支持python客户端的批量？

[ghost]

+1

node-redis客户端，ReplyError: Err unknown or unsupported command 'exec'

[baotiao]

目前暂时不支持 exec 命令

[fancy-rabbit]

pipeline 的时候不要用 transaction（就是不要用 multi/exec），python 客户端有选项的，仔细看一下

[chenyingjie2012]

raise response
redis.exceptions.ResponseError: wrong number of arguments or unsupported command

我的也出现了这个问题，这个问题你是怎么解决的呢？

[Leviathan1995]

@chenyingjie2012 应该是执行了pika目前还不支持的redis命令

pika目前支持的接口

[chenyingjie2012]

好像跟我遇到问题不是一个东西，举个例子啊
import redis
r=redis.StrictRedis(host='10.40.0.70',port='9221')
r.hset(name='search', key='google', value='second')
r.hset(name='search', key='baidu', value='top1@china')
pipeline = r.pipeline()
pipeline.hmget(name='search', key=['google', 'baidu']) #有大量这种查询，所以为了减少网络延迟，想用redis提供的pipeline功能
pipeline.execute()
就开始报错了，那个pika 查了一下不是我用的这个redis的python客户端，各位，这种问题用redis pipeline怎么搞定

[chenyingjie2012]

@Leviathan1995 忘了at了……

[Leviathan1995]

和上面一个问题啊

[chenyingjie2012]

@Leviathan1995 请教一下，pika是什么东西呀，不懂这个呀，去好好看看你分想的那个链接先

[Leviathan1995]

@chenyingjie2012 看一下wiki 有详细的介绍

[ZoroSunCT]

初始化pipeline时，把transaction设为False,
pipeline = self._connection.pipeline(transaction=False)