【中间件篇-Redis缓存数据库02】Redis高级特性和应用(慢查询、Pipeline、事务、Lua)

import redis
 
# 连接Redis
client = redis.StrictRedis(host='localhost', port=6379, db=0)
 
# 慢查询
client.config_set('slowlog-log-slower-than', 10000)  # 设置慢查询的阈值为10毫秒
client.config_get('slowlog-log-slower-than')         # 获取当前的慢查询阈值
client.slowlog_get(10)                                # 获取最近的10条慢查询
 
# Pipeline
pipeline = client.pipeline()
pipeline.set('key1', 'value1')
pipeline.set('key2', 'value2')
pipeline.set('key3', 'value3')
results = pipeline.execute()                          # 批量执行
 
# 事务
with client.pipeline() as pipe:
    pipe.multi()                                      # 开启事务
    pipe.set('key', 'value')
    pipe.incr('counter')
    pipe.execute()                                    # 执行事务
 
# Lua脚本
script = """
local value = redis.call('get', KEYS[1])
if value then
    return redis.call('incr', KEYS[1])
else
    return 0
end
"""
lua_script = client.register_script(script)
result = lua_script(keys=['mykey'], client=client)  # 使用Lua脚本

这段代码展示了如何在Python中使用redis-py库来操作Redis的慢查询、Pipeline和Lua脚本功能。首先，我们设置了慢查询的阈值，并获取了最近的慢查询日志。接着，我们使用Pipeline来批量执行设置键值的操作。最后，我们演示了如何使用事务和Lua脚本来原子性地执行一系列操作。