> db.urilist.find() { "_id" : ObjectId("6787610fb3a57bc85615da73"), "_link" : { "item" : [ { "href" : "http://127.0.0.1:29510/nnrf-nfm/v1/nf-instances/NF_INSTANCE_ID_12345" } ] }, "nfType" : "AMF" } { "_id" : ObjectId("678764d8b3a57bc85615da75"), ...-Go服务器开发

要将给定的 MongoDB 文档记录存储到 Redis 中，可以使用 Redis 的哈希（hash）数据结构来组织每个字段的数据。以下是如何将你提供的两个记录转换并存储到 Redis 的示例。

示例文档

你提供了两个 MongoDB 记录，如下所示：

{
  "_id": ObjectId("6787610fb3a57bc85615da73"),
  "_link": {
    "item": [
      {
        "href": "http://127.0.0.1:29510/nnrf-nfm/v1/nf-instances/NF_INSTANCE_ID_12345"
      }
    ]
  },
  "nfType": "AMF"
}

{
  "_id": ObjectId("678764d8b3a57bc85615da75"),
  "nfType": "SMF",
  "_link": {
    "item": [
      {
        "href": "http://127.0.0.1:29510/nnrf-nfm/v1/nf-instances/smf_12345"
      },
      {
        "href": "http://127.0.0.1:29510/nnrf-nfm/v1/nf-instances/smf_update_12345"
      },
      {
        "href": "http://127.0.0.1:29510/nnrf-nfm/v1/nf-instances/smf_update_1"
      }
    ]
  }
}

存储方案

为了在 Redis 中有效地存储这些信息，我们可以将每条记录用一个唯一键表示，并使用哈希表来保存各个字段和链接。我们还可以为 _link 中的 item 数组生成一个单独的键（比如，分割为多个哈希表或以 JSON 字符串形式保存）。

Python 示例代码

下面是如何在 Python 中实现此操作的示例：

import redis
import json
# 创建Redis连接
redis_client = redis.StrictRedis(host='localhost', port=6379, db=0)
# 定义要存储的数据
records = [
    {
        "_id": "6787610fb3a57bc85615da73", 
        "_link": {"item": [{"href": "http://127.0.0.1:29510/nnrf-nfm/v1/nf-instances/NF_INSTANCE_ID_12345"}]},
        "nfType": "AMF"
    },
    {
        "_id": "678764d8b3a57bc85615da75",
        "_link": {"item": [
            {"href":"http://127.0.0.1:29510/nnrf-nfm/v1/nf-instances/smf_12345"},
            {"href":"http://127.0.0.1:29510/nnrf-nfm/v1/nf-instances/smf_update_12345"},
            {"href":"http://127.0.0.1:29510/nnrf-nfm/v1/nf-instances/smf_update_1"}
        ]},
        "nfType":"SMF"
    }
]
# 将数据存入Redis中
for record in records:
    # 使用_id作为Redis中的key
    key = f"record:{record['_id']}"
    
    # 存储基本信息
    redis_client.hset(key, mapping={
        'nfType': record['nfType'],
        '_link': json.dumps(record['_link'])  # 将_link转换为JSON字符串以存储
    })
# 验证存储的数据
for record in records:
    key = f"record:{record['_id']}"
    retrieved_record = redis_client.hgetall(key)
    
    print(f"Retrieved from Redis for ID {record['_id']}:")
    print({k.decode('utf-8'): v.decode('utf-8') for k, v in retrieved_record.items()})