Python连接Redis进行增删改查(CRUD)操作

pip install redis

import redis

# 连接到 Redis 服务
r = redis.StrictRedis(host='localhost', port=6379, db=0, decode_responses=True)

# 设置一个字符串类型的键值对
r.set('name', 'John Doe')

# 设置多个键值对
r.mset({'age': 30, 'city': 'New York'})

# 获取单个键的值
name = r.get('name')
print(f'Name: {name}')  # 输出: Name: John Doe

# 获取多个键的值
values = r.mget('name', 'age', 'city')
print(values)  # 输出: ['John Doe', '30', 'New York']

# 更新键 'age' 的值
r.set('age', 35)
print(r.get('age'))  # 输出: 35

# 删除键 'city'
r.delete('city')
print(r.get('city'))  # 输出: None，因为键 'city' 已被删除

# 检查键 'name' 是否存在
exists = r.exists('name')
print(exists)  # 输出: True

# 设置键 'name' 在 10 秒后过期
r.expire('name', 10)

# 获取键 'name' 的剩余过期时间
ttl = r.ttl('name')
print(ttl)  # 输出: 剩余的秒数

# 设置哈希键 'user'，并存储字段 'name' 和 'age'
r.hset('user', 'name', 'John Doe')
r.hset('user', 'age', 30)

# 获取哈希中的字段
name = r.hget('user', 'name')
age = r.hget('user', 'age')
print(f'Name: {name}, Age: {age}')

import redis

# 连接到 Redis 服务
r = redis.StrictRedis(host='localhost', port=6379, db=0, decode_responses=True)

# 1. 增加（Create）操作
# 设置字符串类型的键值对
r.set('name', 'John Doe')
r.set('age', 30)
r.set('city', 'New York')

# 设置一个哈希类型的键值对
r.hset('user:1000', 'name', 'Alice')
r.hset('user:1000', 'age', 25)

# 批量设置多个键值对
r.mset({'country': 'USA', 'language': 'English'})

# 打印结果
print(f"Set 'name': {r.get('name')}")
print(f"Set 'age': {r.get('age')}")
print(f"Set 'city': {r.get('city')}")
print(f"Set 'country' and 'language': {r.mget('country', 'language')}")

# 2. 查询（Read）操作
# 获取单个键值
print("\n--查询操作--")
name = r.get('name')
print(f"Name: {name}")

# 获取多个键值
user_data = r.mget('name', 'age', 'city', 'country', 'language')
print(f"User data: {user_data}")

# 获取哈希中的字段
user_name = r.hget('user:1000', 'name')
user_age = r.hget('user:1000', 'age')
print(f"User 1000 Name: {user_name}, Age: {user_age}")

# 3. 更新（Update）操作
# 更新字符串类型的值
r.set('age', 35)
print(f"Updated 'age': {r.get('age')}")

# 更新哈希中的字段
r.hset('user:1000', 'age', 26)
print(f"Updated 'user:1000' age: {r.hget('user:1000', 'age')}")

# 4. 删除（Delete）操作
# 删除单个键
r.delete('city')
print(f"Deleted 'city', current value: {r.get('city')}")

# 删除哈希中的字段
r.hdel('user:1000', 'name')
print(f"Deleted 'name' from 'user:1000', current fields: {r.hgetall('user:1000')}")

# 5. 设置键的过期时间
# 设置 'country' 键在 5 秒后过期
r.expire('country', 5)
print(f"Is 'country' key expired? {r.exists('country')}")  # 初始为 True

# 等待 6 秒钟，键应该过期
import time
time.sleep(6)
print(f"After waiting 6 seconds, is 'country' expired? {r.exists('country')}")  # 应该为 False

# 6. 其他操作：检查键是否存在
key_exists = r.exists('name')
print(f"Does 'name' exist? {key_exists}")

# 获取键的剩余生存时间
ttl = r.ttl('age')
print(f"The remaining time-to-live for 'age' is: {ttl} seconds")

# 获取哈希中所有字段和值
user_data_all = r.hgetall('user:1000')
print(f"All fields in 'user:1000': {user_data_all}")

# 完成
print("\n-- 完成所有操作 --")

Set 'name': John Doe
Set 'age': 30
Set 'city': New York
Set 'country' and 'language': ['USA', 'English']

--查询操作--
Name: John Doe
User data: ['John Doe', '30', 'New York', 'USA', 'English']
User 1000 Name: Alice, Age: 25

Updated 'age': 35
Updated 'user:1000' age: 26
Deleted 'city', current value: None
Deleted 'name' from 'user:1000', current fields: {'age': '26'}

Is 'country' key expired? True
After waiting 6 seconds, is 'country' expired? False
Does 'name' exist? True
The remaining time-to-live for 'age' is: -1 seconds
All fields in 'user:1000': {'age': '26'}

-- 完成所有操作 --