使用Python创建带复合键的Redis数据库

首先明确：不需要用ZADD。ZADD是Redis有序集合（Sorted Set）的命令，核心用于带分值的元素排序、排名场景，和你基于复合键存储结构化业务数据的需求不匹配。下面是几种适合的实现方案：

方案1：使用哈希（Hash）结构（推荐） #

Redis的哈希结构天然适合存储键值对形式的结构化数据，我们可以把customer_id和product_code拼接成唯一的Redis键名（遵循Redis冒号分隔的命名规范），然后把剩余字段存入哈希中。

代码示例 #

import redis

# 初始化Redis连接（根据你的实际配置修改）
r = redis.Redis(host='localhost', port=6379, db=0, decode_responses=True)

# 待存储的业务数据
data = {
    "customer_id": "C001",
    "order_id": "O789",
    "product_code": "P007",
    "quantity": 1000
}

# 生成复合键：用冒号分隔两个键字段，保证唯一性
composite_key = f"customer_product:{data['customer_id']}:{data['product_code']}"

# 将数据存入哈希：可以只存非键字段，也可以全量存储
r.hset(composite_key, mapping={
    "order_id": data["order_id"],
    "quantity": data["quantity"]
})

# 读取数据示例
stored_data = r.hgetall(composite_key)
print(stored_data)
# 输出: {'order_id': 'O789', 'quantity': '1000'}

方案2：存储完整JSON字符串 #

如果需要保留原始JSON结构，可以直接将JSON序列化后存入Redis字符串类型，复合键规则和上面一致。

代码示例 #

import redis
import json

r = redis.Redis(host='localhost', port=6379, db=0, decode_responses=True)
data = {
    "customer_id": "C001",
    "order_id": "O789",
    "product_code": "P007",
    "quantity": 1000
}
composite_key = f"customer_product:{data['customer_id']}:{data['product_code']}"

# 序列化JSON并存储
r.set(composite_key, json.dumps(data))

# 读取并反序列化
stored_json = r.get(composite_key)
stored_data = json.loads(stored_json)
print(stored_data)
# 输出: {'customer_id': 'C001', 'order_id': 'O789', 'product_code': 'P007', 'quantity': 1000}

方案3：使用RedisJSON（进阶） #

如果你的Redis服务器安装了RedisJSON扩展（需要单独部署），可以直接存储和操作JSON数据，支持按JSON路径查询修改，灵活性更高。

代码示例 #

import redis
from redis.commands.json.path import Path

r = redis.Redis(host='localhost', port=6379, db=0, decode_responses=True)
data = {
    "customer_id": "C001",
    "order_id": "O789",
    "product_code": "P007",
    "quantity": 1000
}
composite_key = f"customer_product:{data['customer_id']}:{data['product_code']}"

# 存储JSON数据
r.json().set(composite_key, Path.root_path(), data)

# 读取完整数据
stored_data = r.json().get(composite_key)
print(stored_data)

# 按路径读取单个字段（比如只取quantity）
quantity = r.json().get(composite_key, Path("$.quantity"))
print(quantity)
# 输出: [1000]

关键说明 #

• 复合键命名：用冒号分隔字段是Redis社区通用的最佳实践，既保证键的唯一性，又方便后续用SCAN命令批量匹配（比如customer_product:C001:*可以匹配C001用户的所有产品数据）。
• ZADD不适用的原因：有序集合的核心是元素的分值排序，无法直接存储结构化的键值对数据，完全不符合你的业务场景。

内容的提问来源于stack exchange，提问作者MeatBallKing