gistfile1.txt

.. with r.pipeline() as pipe:
...     while 1:
...         try:
...             # 关注一个key
...             pipe.watch('xiaorui.cc')
...             current_value = pipe.get('xiaorui.cc')
...             next_value = int(current_value) + 1
...             #事物开始
...             pipe.multi()
...             pipe.set('xiaorui.cc', next_value)
...             # 事务结束
...             pipe.execute()
...             # 把命令推送过去
...             break
...        except WatchError:
...              #如果客户端有变动的话，那么就会触发这个异常。 
...             continue