建立连接

# 本地
redis_con = redis.Redis()

# 指定host
redis_con = redis.Redis(
host="10.82.193.194",
port=6380,
password="",
db=2
)

集合去重

redis_con.sismember(key, value)  # 是否存在
redis_con.sadd(key, value) # 添加单条数据
redis_con.sadd(key, *lst) # 添加列表
redis_con.smembers(key) # 获取全部值
redis_con.spop('your_key') # 从集合中弹出一个元素
>>> return [bytes, bytes ...]

字符串

length = redis_conn.llen(key)
redis_conn.lpush(queue_key, *data_lst)

列表

length = redis_conn.llen(key)
redis_conn.lpush(queue_key, *data_lst)

模糊匹配,删除键

# 用于存储匹配的键
keys_to_delete = []

# 使用scan命令迭代匹配的键
cursor = '0'
while cursor != 0:
cursor, keys = r.scan(cursor=cursor, match='cxs:*', count=1000)
keys_to_delete.extend(keys)

# 删除所有匹配的键
if keys_to_delete:
r.delete(*keys_to_delete)