python 使用redis 工程化的写法

Redis 是一个非常流行的内存数据存储系统，它可以用于缓存、分布式锁、消息队列等场景。在 Python 中，我们通常使用 Redis 的 Python 客户端库——redis-py 来操作 Redis。

下面是 Redis 工程化的 Python 写法：

1. 安装redis-py

pip install redis

2. 连接 Redis

import redis

# 创建连接池
pool = redis.ConnectionPool(host='localhost', port=6379, db=0)

# 创建 Redis 客户端
r = redis.Redis(connection_pool=pool)

# 测试连接是否成功
print(r.ping())  # 输出：True

3. 设置键值对

# 设置键值对
r.set('name', 'John')

# 获取值
name = r.get('name')
print(name.decode())  # 输出：John

4. 设置过期时间

# 设置键值对，并设置过期时间为 60 秒
r.setex('name', 60, 'John')

# 获取值
name = r.get('name')
print(name.decode())  # 输出：John

# 等待 60 秒后获取值
time.sleep(60)
name = r.get('name')
print(name)  # 输出：None

5. 使用管道操作

# 创建管道
pipe = r.pipeline()

# 将多个命令放入管道中
pipe.set('name', 'John')
pipe.set('age', 18)

# 执行命令
pipe.execute()

# 获取值
name = r.get('name')
age = r.get('age')
print(name.decode(), age.decode())  # 输出：John 18

6. 使用 Lua 脚本

# 定义 Lua 脚本
script = """
local counter = redis.call("incr", KEYS[1])
if tonumber(counter) == 1 then
    redis.call("expire", KEYS[1], ARGV[1])
    return 1
elseif tonumber(counter) > tonumber(ARGV[2]) then
    return 0
else
    return 1
end
"""

# 加载 Lua 脚本
script_sha = r.script_load(script)

# 执行 Lua 脚本
result = r.evalsha(script_sha, 1, 'limit:127.0.0.1', 60, 10)
print(result)  # 输出：1

以上是 Redis 工程化的 Python 写法，可以更好地适应实际项目的需求。