建立连接

# 本地
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)