高级功能#

关于线程的说明#

Redis 客户端实例可以在线程之间安全共享。在内部，连接实例仅在命令执行期间从连接池中检索，并在执行后直接返回到池中。命令执行不会修改客户端实例上的状态。

但是，有一个需要注意的地方：Redis SELECT 命令。SELECT 命令允许您切换连接当前使用的数据库。该数据库将保持选中状态，直到选择另一个数据库或连接关闭。这会导致一个问题，即连接可能返回到连接到不同数据库的池中。

因此，redis-py 在客户端实例中没有实现 SELECT 命令。如果您在同一个应用程序中使用多个 Redis 数据库，则应为每个数据库创建单独的客户端实例（以及可能单独的连接池）。

在不同线程之间传递 PubSub 或 Pipeline 对象是不安全的。

管道#

默认管道#

管道是 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, b'baz']

为了方便使用，所有缓冲到管道中的命令都返回管道对象本身。因此，调用可以像这样链接

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

此外，管道还可以确保缓冲的命令作为一组原子地执行。这是默认行为。如果您想禁用管道的原子性，但仍然想缓冲命令，您可以关闭事务。

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

一个常见的问题是，当需要原子事务，但需要在事务中使用之前从 Redis 中检索值时。例如，假设 INCR 命令不存在，我们需要在 Python 中构建 INCR 的原子版本。

完全幼稚的实现可以获取值，在 Python 中递增它，然后将新值设置回去。但是，这不是原子的，因为多个客户端可能同时执行此操作，每个客户端都从 GET 获取相同的值。

输入 WATCH 命令。WATCH 提供在开始事务之前监视一个或多个键的能力。如果在执行该事务之前任何这些键发生更改，则整个事务将被取消，并且会引发 WatchError。为了实现我们自己的客户端 INCR 命令，我们可以执行以下操作

>>> with r.pipeline() as pipe:
...     while True:
...         try:
...             # put a WATCH on the key that holds our sequence value
...             pipe.watch('OUR-SEQUENCE-KEY')
...             # after WATCHing, the pipeline is put into immediate execution
...             # mode until we tell it to start buffering commands again.
...             # this allows us to get the current value of our sequence
...             current_value = pipe.get('OUR-SEQUENCE-KEY')
...             next_value = int(current_value) + 1
...             # now we can put the pipeline back into buffered mode with MULTI
...             pipe.multi()
...             pipe.set('OUR-SEQUENCE-KEY', next_value)
...             # and finally, execute the pipeline (the set command)
...             pipe.execute()
...             # if a WatchError wasn't raised during execution, everything
...             # we just did happened atomically.
...             break
...        except WatchError:
...             # another client must have changed 'OUR-SEQUENCE-KEY' between
...             # the time we started WATCHing it and the pipeline's execution.
...             # our best bet is to just retry.
...             continue

请注意，由于 Pipeline 必须在 WATCH 期间绑定到单个连接，因此必须注意通过调用 reset() 方法将连接返回到连接池。如果 Pipeline 用作上下文管理器（如上面的示例所示），则会自动调用 reset()。当然，您可以通过显式调用 reset() 来手动执行此操作

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

名为“transaction”的便捷方法存在于处理处理和重试监视错误的所有样板代码。它接受一个可调用对象，该可调用对象应期望一个参数，一个管道对象，以及要监视的任意数量的键。我们上面的客户端 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]

请确保在传递给 Redis.transaction 的可调用对象中调用 pipe.multi()，然后再执行任何写入命令。

集群中的管道#

ClusterPipeline 是 RedisCluster 的一个子类，它为集群模式下的 Redis 管道提供支持。当调用 execute() 命令时，所有命令都会根据它们将在其上执行的节点进行分组，然后由各个节点并行执行。管道实例将等待所有节点响应，然后再将结果返回给调用者。命令响应以列表形式返回，排序顺序与发送顺序相同。管道可用于显着提高 Redis 集群的吞吐量，方法是显着减少客户端和服务器之间的网络往返次数。

>>> with rc.pipeline() as pipe:
...     pipe.set('foo', 'value1')
...     pipe.set('bar', 'value2')
...     pipe.get('foo')
...     pipe.get('bar')
...     print(pipe.execute())
[True, True, b'value1', b'value2']
...     pipe.set('foo1', 'bar1').get('foo1').execute()
[True, b'bar1']

请注意：- RedisCluster 管道目前仅支持基于键的命令。- 管道从集群的参数中获取其“read_from_replicas”值。因此，如果在集群实例中启用了从副本读取，则管道也将将读取命令定向到副本。- 集群模式下不支持“transaction”选项。在非集群模式下，执行管道时可以使用“transaction”选项。这会将管道命令包装在 MULTI/EXEC 命令中，并有效地将管道命令转换为单个事务块。这意味着所有命令都按顺序执行，不会受到其他客户端的任何干扰。但是，在集群模式下，这是不可能的，因为命令根据其各自的目标节点进行分区。这意味着我们无法将管道命令转换为一个事务块，因为在大多数情况下，它们被拆分为几个较小的管道。

高级功能#

关于线程的说明#

管道#

默认管道#

集群中的管道#

发布/订阅#

分片发布订阅#

监控#