如何结合Redis-Python Pipeline与JSON实现批量插入并按内容检索

你用pipe.set()存入的是普通字符串，而非RedisJSON类型的结构化数据。RedisSearch的索引是基于RedisJSON的字段（比如你示例里的key字段）建立的，普通字符串不会被索引解析，所以搜索时找不到这些数据。

在Pipeline中使用RedisJSON的json().set()方法批量插入结构化数据，而非普通的set()。具体代码如下：

import ast
from redis import Redis
from redis.commands.json.path import Path
from redis.commands.search import Search
from redis.commands.search.query import Query

# 初始化Redis客户端和搜索客户端
r = Redis(host='localhost', port=6379, db=0)
rs = Search(r, index_name='your_index_name')  # 替换成你的实际索引名

# 准备批量数据（示例为4条，可扩展到10k条）
data_list = [
    {"key": "glooler-61246", "val": "loltest"},
    {"key": "glooler-61247", "val": "loltest2"},
    {"key": "glooler-61248", "val": "loltest3"},
    {"key": "glooler-61249", "val": "loltest4"}
]

# 创建Pipeline并批量执行JSON插入操作
pipe = r.pipeline()
for item in data_list:
    key = f"a:{item['key']}"
    pipe.json().set(key, Path.root_path(), item)

# 执行批量操作
pipe.execute()

# 验证搜索结果
result = rs.search(Query("glooler"))
print(result.docs)

1. 确保你的RedisSearch索引已正确配置，包含了JSON中的key字段（比如创建索引时指定JSONField("$.key", as_name="key")）。如果索引未配置对应字段，即使存入JSON数据也无法被检索。
2. 之前用pipe.set()存入的普通字符串数据，需要删除或转换为RedisJSON格式才能被索引：

   # 转换示例：将已存的字符串转成RedisJSON
   old_key = "a:glooler-61246"
   str_data = r.get(old_key)
   if str_data:
       json_data = ast.literal_eval(str_data.decode('utf-8'))
       r.json().set(old_key, Path.root_path(), json_data)
       r.delete(old_key)  # 删除原字符串键
   

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