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 11:59 -- 更新于2020-10-19 13:06 -- 0 条评论