如何使用Redis搜索存储在键中的JSON数据？

你当前将完整JSON存入Redis字符串键，通过本地遍历匹配的效率较低，以下是两种Redis原生实现方案：

方案1：使用RedisJSON模块（推荐） #

RedisJSON是官方扩展，专为JSON数据设计，支持JSONPath查询，能直接在服务器端完成精准匹配，无需拉取全量数据到本地。

操作步骤： #

1. 安装RedisJSON：可通过Docker快速部署docker run -p 6379:6379 redislabs/rejson:latest，或根据Redis版本编译安装模块。
2. 安装客户端依赖：执行pip install redis-rejson获取RedisJSON的Python客户端。
3. 重构数据存储与查询：将原字符串格式的JSON转为RedisJSON类型存储，再用JSONPath执行匹配：

from rejson import Client, Path
import os
import json

# 初始化RedisJSON客户端
rj = Client(host='localhost', port=6379, db=0)
BASE_DIR = '.'  # 替换为你的实际目录路径

# 检查数据是否存在，不存在则导入
if not rj.exists('mykey'):
    with open(os.path.join(BASE_DIR, "my_file.json")) as fl:
        data = json.load(fl)
        rj.jsonset('mykey', Path.rootPath(), data)
else:
    # 定义要匹配的目标JSON对象
    search_target = {
        "key": "value",
        "key2": {
            "key": "val"
        }
    }
    # 构造JSONPath查询语句，匹配all_data数组中与目标完全一致的元素
    query_path = Path(f'$..all_data[?(@ == {json.dumps(search_target)})]')
    match_result = rj.jsonget('mykey', query_path)
    
    if match_result:
        print("找到匹配对象：", match_result)
    else:
        print("未找到匹配对象")

JSONPath语法说明：$..all_data[?(@ == 目标JSON)]会递归定位all_data数组，筛选出与目标结构完全一致的元素。

方案2：使用Lua脚本（兼容无RedisJSON环境） #

若无法安装RedisJSON模块，可通过Lua脚本在Redis服务器端完成遍历匹配，避免全量数据传输到客户端：

import redis
import os
import json

rd = redis.StrictRedis(host="localhost", port=6379, db=0)
BASE_DIR = '.'

if not rd.get("mykey"):
    with open(os.path.join(BASE_DIR, "my_file.json")) as fl:
        data = json.load(fl)
        rd.set("mykey", json.dumps(data))
else:
    search_target = {
        "key": "value",
        "key2": {
            "key": "val"
        }
    }
    target_str = json.dumps(search_target)
    
    # 定义Lua脚本，在服务器端解析JSON并遍历匹配
    match_script = """
        local raw_data = redis.call('GET', KEYS[1])
        local data = cjson.decode(raw_data)
        local target_str = ARGV[1]
        local matches = {}
        
        for _, item in ipairs(data['all_data']) do
            if cjson.encode(item) == target_str then
                table.insert(matches, item)
            end
        end
        
        return cjson.encode(matches)
    """
    
    # 执行Lua脚本
    result_str = rd.eval(match_script, 1, 'mykey', target_str)
    match_result = json.loads(result_str)
    
    if match_result:
        print("找到匹配对象：", match_result)
    else:
        print("未找到匹配对象")

注意事项 #

• 优先选择RedisJSON方案，它支持更复杂的查询场景（如部分字段匹配、范围筛选），维护性和性能更优。
• 若需高频搜索，建议将数组内的每个JSON对象单独存储为Redis哈希或RedisJSON文档，并配合RedisSearch建立索引，进一步提升查询效率。

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