db.NfProfile.find() { "_id" : ObjectId("6787610fb3a57bc85615da74"), "nfType" : "AMF", "nfStatus" : "REGISTERED", "plmnList" : [ { "mcc" : "460", "mnc" : "01" } ], "ipv4Addresses" : [ "192.168.0.1" ], "nfInstanceId" : "NF_INSTANCE_ID_12345" } { "

要将上述 MongoDB 中的文档结构存储到 Redis 中，你可以选择使用哈希表（Hash）来表示每个记录。每个记录的 _id 可以用作 Redis 键的一部分，哈希表中的字段则可以对应文档中的各个属性。

下面是一个示例，展示如何将这些记录转换并存储到 Redis 中，以及如何从 Redis 读取它们。

示例代码

假设你已经有 go-redis 和 mongo-go-driver 包安装，你可以按照以下方式进行操作：

1. 将数据从 MongoDB 存储到 Redis

package main
import (
	"context"
	"fmt"
	"log"
	"go.mongodb.org/mongo-driver/bson"
	"go.mongodb.org/mongo-driver/mongo"
	"go.mongodb.org/mongo-driver/mongo/options"
	"github.com/go-redis/redis/v8"
)
type NfProfile struct {
	ID             string        `bson:"_id"`
	NfType         string        `bson:"nfType"`
	NfStatus       string        `bson:"nfStatus"`
	PmlnList       []Plmn        `bson:"plmnList"`
	Ipv4Addresses  []string      `bson:"ipv4Addresses"`
	NfInstanceId   string        `bson:"nfInstanceId"`
}
type Plmn struct {
	MCC string `bson:"mcc"`
	MNC string `bson:"mnc"`
}
func main() {
	ctx := context.Background()
	// MongoDB配置
	mongoClient, err := mongo.Connect(ctx, options.Client().ApplyURI("mongodb://localhost:27017"))
	if err != nil {
		log.Fatalf("Failed to connect to MongoDB: %v", err)
	}
	defer mongoClient.Disconnect(ctx)
	nfCollection := mongoClient.Database("your_database_name").Collection("NfProfile")
	cursor, err := nfCollection.Find(ctx, bson.D{})
	if err != nil {
		log.Fatalf("Failed to find documents: %v", err)
	}
	defer cursor.Close(ctx)
	rdb := redis.NewClient(&redis.Options{
		Addr: "localhost:6379",
	})
	defer rdb.Close()
	for cursor.Next(ctx) {
		var profile NfProfile
		if err := cursor.Decode(&profile); err != nil {
			log.Printf("Failed to decode document: %v", err)
			continue
		}
		key := fmt.Sprintf("nfprofile:%s", profile.ID) // 使用 _id 作为键前缀
     
     // 将数据存储为哈希表形式
     _, err = rdb.HSet(ctx, key,
     	map[string]interface{}{
     	    "nfType":         profile.NfType,
     	    "nfStatus":       profile.NfStatus,
     	    "plmnList":       profile.PmlnList,
     	    "ipv4Addresses":  profile.Ipv4Addresses,
     	    "nfInstanceId":   profile.NfInstanceId,
     }).Result()
     
     if err != nil {
         log.Printf("Error saving data to Redis: %v", err)
     }
   }
   
   if err := cursor.Err(); err != nil {
       log.Fatalf("Cursor error: %v", err)
   }
   fmt.Println("Data successfully migrated from MongoDB to Redis!")
}

2. 从 Redis 获取特定类型的记录

在之前的示例中，你已经了解了如何根据特定条件查询Redis的数据。这次我们会针对你的数据结构做相应调整。

func getRecordsByNfType(ctx context.Context, rdb *redis.Client, nfType string) ([]NfProfile, error) {
	keyPattern := "nfprofile:*" // 匹配所有键
	var profiles []NfProfile    // 用于存储符合条件的记录
	
	iter := rdb.Scan(ctx, 0, keyPattern, 0).Iterator()
	for iter.Next(ctx) {
		key := iter.Val()
		
	  recordData, err := rdb.HGetAll(ctx, key).Result()
	  if err != nil || len(recordData) == 0 { 
	     continue 
	  }
	  var profile NfProfile
	  profile.ID = key[len("nfprofile:"):] // 去掉前缀以获取 ID
	  // 手动将数据赋值给结构体属性
	  if val, exists := recordData["nfType"]; exists {
		  profile.NfType = val
	  }
	  if val, exists := recordData["nfStatus"]; exists { 
		  profile.NfStatus = val 
	  }
	  
	  // 提取其他字段...
    profiles = append(profiles, profile)  
    }
    if iter.Err() != nil { return nil , iter.Err() }
    return profiles,nil 
}
// 在主函数中调用查询方法并输出结果。