文档章节

Python client for Redis 官翻文档2.10.1(三)

山下狮子
 山下狮子
发布于 2014/06/20 16:59
字数 1049
阅读 1532
收藏 4

Pipelines

管道

管道是Redis的子类,它支持缓冲多个命令,一次性发送到服务器去执行。可以大大的提高性能,减少服务器到客户端之间的TCP来回数据包。

管道的简单使用:

>>> r = redis.Redis(...)
>>> r.set('bing', 'baz')
>>> # Use the pipeline() method to create a pipeline instance
>>> pipe = r.pipeline()
>>> # The following SET commands are buffered
>>> pipe.set('foo', 'bar')
>>> pipe.get('bing')
>>> # the EXECUTE call sends all buffered commands to the server, returning
>>> # a list of responses, one for each command.
>>> pipe.execute()
[True, 'baz']

For ease of use, all commands being buffered into the pipeline return the pipeline object itself. Therefore calls can be chained like:

为了便于使用,可以像下面这样写。

>>> pipe.set('foo', 'bar').sadd('faz', 'baz').incr('auto_number').execute()
[True, True, 6]

In addition, pipelines can also ensure the buffered commands are executed atomically as a group. This happens by default. If you want to disable the atomic nature of a pipeline but still want to buffer commands, you can turn off transactions.

此外,管道还可以确保缓冲命令作为一组去执行。默认就是这样(就是管道开启了事务)。

要是想禁用原子性质的管道,还想缓冲命令,像下面这样设置。

>>> pipe = r.pipeline(transaction=False)

A common issue occurs when requiring atomic transactions but needing to retrieve values in Redis prior for use within the transaction. For instance, let's assume that the INCR command didn't exist and we need to build an atomic version of INCR in Python.

一个常见的问题:有些情况下需要先获得一条命令的返回值,然后在执行这个值的下一条命令,而事物中只有当所有命令都一次执行完成后才能得到每个结果的返回值。例如,假设INCR命令不存在,我们在python中实现带有原子性质的INCR命令。

The completely naive implementation could GET the value, increment it in Python, and SET the new value back. However, this is not atomic because multiple clients could be doing this at the same time, each getting the same value from GET.

通过GET获取key存在的值,然后通过SET设置新的值,但这不是原子性质的。同一时间多个客户端可以这么操作,每个都可以使用GET获取相同的值。

Enter the WATCH command. WATCH provides the ability to monitor one or more keys prior to starting a transaction. If any of those keys change prior the execution of that transaction, the entire transaction will be canceled and a WatchError will be raised. To implement our own client-side INCR command, we could do something like this:

WATCH命令。WATCH可以监视一个或多个key在开启事务之前。如果被监视的key在事务执行之前被修改过了,接下来的事务操作会被拒绝执行。实现我们自己客户端的INCR命令,可以像下面这样:

>>> with r.pipeline() as pipe:
...     while 1:
...         try:
...             pipe.watch('OUR-SEQUENCE-KEY') #监视的key
...             current_value = pipe.get('OUR-SEQUENCE-KEY')#获取存在的key值
...             next_value = int(current_value) + 1#计算
...             pipe.multi()#开启事务
...             pipe.set('OUR-SEQUENCE-KEY', next_value)#设置key值
...             pipe.execute()#执行
....            break#执行成功退出循环
...        except WatchError:
....             continue#如果监视的值被别的客户端动了,会引发错误,但我们还得继续执行
                            #因为我们还没让key的值改变,直到修改了key的值,才结束

Note that, because the Pipeline must bind to a single connection for the duration of a WATCH, care must be taken to ensure that the connection is returned to the connection pool by calling the reset() method. If the Pipeline is used as a context manager (as in the example above) reset() will be called automatically. Of course you can do this the manual way by explicity calling reset():

注意:因为管道在执行WATCH期间绑定到一个连接,通过调用reset()方法确保连接被放回到连接池。

如果管道只作为命令缓冲,reset方法会自动被调用,你可以手动调用复位。

>>> pipe = r.pipeline()
>>> while 1:
...     try:
...         pipe.watch('OUR-SEQUENCE-KEY')      
            ...
...         pipe.execute()
...         break
...     except WatchError:
...         continue
...     finally:
...         pipe.reset()

A convenience method named "transaction" exists for handling all the boilerplate of handling and retrying watch errors. It takes a callable that should expect a single parameter, a pipeline object, and any number of keys to be WATCHed. Our client-side INCR command above can be written like this, which is much easier to read:

存在一个名为transaction的便利方法,可以处理上面的情况,尝试下看看情况。

有一个可调用参数-管道对象,或者其他的需要WATCH监视的key.

我们的客户端INCR命令可以写成下面这样,更简单和易读。

>>> def client_side_incr(pipe):
...     current_value = pipe.get('OUR-SEQUENCE-KEY')
...     next_value = int(current_value) + 1
...     pipe.multi()
...     pipe.set('OUR-SEQUENCE-KEY', next_value)
>>>
>>> r.transaction(client_side_incr, 'OUR-SEQUENCE-KEY')
[True]


© 著作权归作者所有

共有 人打赏支持
山下狮子
粉丝 24
博文 115
码字总数 58167
作品 0
东城
程序员
私信 提问
Python client for Redis 官翻文档2.10.1(一)

Python client for Redis key-value store redis针对python的客户端, github地址:https://github.com/andymccurdy/redis-py/ 安装: 虽然称redis的python客户端称为redis-py,实际安装时的......

山下狮子
2014/06/19
0
0
Python client for Redis 官翻文档2.10.1(二)

更多的细节 连接池: 在幕后,redis-py 使用连接池管理连接到redis-server的连接.默认, 一旦你创建了一个Redis的实例 ,这个实例相应有自己的连接池。你可以重写此行为,在创建一个Redis实例...

山下狮子
2014/06/20
0
0
jumpserver跳板机安装与配置实战

jumpserver安装与配置 参考jumpserver官网http://docs.jumpserver.org/zh/docs/stepbystep.html 一、准备python3和python虚拟环境 1.1安装依赖包 yum -y install wget sqlite-devel xz gcc ......

jxzhfei
08/15
0
0
Sentry-Bug追踪系统安装.

安装Sentry 本文主要介绍在centos7 下通过docker安装sentry 一. 安装docker 1.确保yum packages 是最新的 2.添加yum repo 3.安装docker 4.启动docker 5.验证docker已经启动 6.安装--Docker ...

_Change_
11/06
0
0
使用 Tsuru 和 Docker 构建自己的 PaaS 系统

该文档描述如何使用 Tsuru 和 Docker 构建自己的私有 PaaS 服务。 文档假设你已经在64位的 Ubuntu 12.04 LTS 上安装了 Tsuru。 安装之前 开始安装之前,需要先安装 curl 和 python-software-...

oschina
2014/04/18
8.1K
19

没有更多内容

加载失败,请刷新页面

加载更多

esxi 更换ssl证书

概述 就是想换一个证书而已,你可以通过下面的途径去申请一个泛解析域名的证书之后再esxi上安装上 使用阿里云域名api申请Let’s Encrypt泛域名免费ssl证书 申请完成证书之后进行下一步 操作 ...

bboysoulcn
17分钟前
1
0
PLC编程入门:梯形图

梯形图(LAD)是PLC编程的最佳可视化语言,它看起来非常类似于继电器电路图,因此如果 你对继电器控制和电子电路有所了解的话,那么学起来会非常容易! 在这个教程中,我们将学习关于使用梯形...

汇智网教程
19分钟前
1
0
Kubernetes 1.13.0的快速升级

Kubernetes 1.13.0已经正式发布,快速升级(含国内镜像快速下载链接)包括升级kubeadm/kubectl/kubelet版本、拉取镜像、升级Kubernetes集群三个主要步骤。注意Kubernetes 1.13.0版本暂时不支...

openthings
33分钟前
2
0
go的卸载和环境变量配个人.bashrc

若是用安装包直接解压 http://download.csdn.net/detail/u010026901/7592581 cd /usr/local tar -zxvf go1.1.2.linux-386.tar.gz(先把安装包移到这个目录) 3.安装 $ cd go/src,$ ./all.b......

dragon_tech
38分钟前
1
0
区块链安全 - 以太坊短地址攻击

1 基础知识 EVM虚拟机在解析合约的字节码时,依赖的是ABI的定义,从而去识别各个字段位于字节码的什么地方。关于ABI,可以阅读这个文档: https://github.com/ethereum/wiki/wiki/Ethereum-C...

HiBlock
49分钟前
1
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部