建立连接

1
2
3
4
5
6
7
8
9
10
# 本地
redis_con = redis.Redis()

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

集合（用于去重）

1
2
3
4
5
redis_con.sismember(key, value)  # 是否存在
redis_con.sadd(key, value)  # 添加单条数据
redis_con.sadd(key, *lst)  # 添加列表
redis_con.smembers(key)  # 获取全部值
>>> return [bytes, bytes ...]

列表

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

字符串

1
2
3
4
5
6
7
8
# 键值分组，命名为 aaa:bbb:ccc
redis_conn.set(key, value)
# 设置过期时间，过期则get为none
redis_conn.expire(key, seconds)
# 存储字典数据
redis_cli.lpush(key, json.dumps(doc))
obj = redis_cli.rpop(key)
doc = json.loads(obj)

模糊匹配，删除键

1
2
3
4
5
6
7
8
9
10
11
12
# 用于存储匹配的键
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)