python:aioredis事务，watch使用
redis在执行任务的过程中，难保别人也会同时对同一个key进行操作。这种情况在耗时较大的Mutil exec下更容易出现。 所以redis引入了watch机制。当一个客户端watch key，如果另一个客户端change了这个key。则watch这个Key的客户端将引发一个错误。 测试代码如下：
async def test_get1(request):
temp_key = 'test:hello'
async with request.app.redis_pool.get() as redis:
await redis.watch(temp_key)
trs = redis.multi_exec()
for i in range(1000):
trs.get(temp_key)
trs.set(temp_key, 'hello')
ret = await trs.execute()
logging.info("ret {}".format(ret))
return html('hello')
async def test_get2(request):
temp_key = 'test:hello'
async with request.app.redis_pool.get() as redis:
while 1:
redis.set(temp_key, 'he')
await asyncio.sleep(0.1)
return html('hello')先执行test2，模拟另一个用户不停的在操作key。再执行test1。此时，在test1中，将引发一个错误。
aioredis.errors.WatchVariableError: ('WatchVariableError errors:', 'WATCH variable has changed')此时，我们Handler这个错误，进行错误处理就行（一般是重试）。
本文参与 腾讯云自媒体分享计划，分享自作者个人站点/博客。
原始发表：2017-08-18 ，如有侵权请联系 cloudcommunity@tencent.com 删除
评论
登录后参与评论
推荐阅读
相关产品与服务
云数据库 Redis
腾讯云数据库 Redis（TencentDB for Redis）是腾讯云打造的兼容 Redis 协议的缓存和存储服务。丰富的数据结构能帮助您完成不同类型的业务场景开发。支持主从热备，提供自动容灾切换、数据备份、故障迁移、实例监控、在线扩容、数据回档等全套的数据库服务。