我知道标题看起来很笼统而且重复，但我已经尝试了之前问题中的许多选项，而且我不能在这里使用结构

我的系统使用消息服务 NATS 在订阅者和发布者之间发送 map 。订阅者获取接收到的 map ，并将其作为文档插入 MongoDB 集合中

我遇到的问题是 float 和整数作为字符串插入!

在我的代码中，recipe 是一个配置文件，用于设置映射中接收到的列的数据类型。把它想象成像这样的一系列键:

• 字符串列:"string",
• 整数列:“整数”

这是使用正确数据类型创建 map 的代码

mapWithCorrectDataTypes := make(map[string]interface{})

    for columnNameFromDataTypesInRecipe, datatypeForColumnInRecipe := range dataTypesFromRecipeForColumns {

    for natsMessageColumn, natsMessageColumnValue := range mapFromNATSMessage {

            //If the column in the NATS message is found in the recipe, format the data as dictated in the recipe
                    if natsMessageColumn == columnNameFromDataTypesInRecipe {

                        if datatypeForColumnInRecipe.(string) == "string" {

                            natsMessageColumnValue = natsMessageColumnValue.(string)
                            mapWithCorrectDataTypes[columnNameFromDataTypesInRecipe] = natsMessageColumnValue
                        }

                        if datatypeForColumnInRecipe.(string) == "int" {

                            convertedInt, err := strconv.Atoi(mapFromNATSMessage[columnNameFromDataTypesInRecipe].(string))
                            if err != nil {
                                fmt.Println("ERROR -->", err)
                            }
                            mapWithCorrectDataTypes[columnNameFromDataTypesInRecipe] = convertedInt
                        }

                        if datatypeForColumnInRecipe.(string) == "float64" {

                            convertedFloat, err := strconv.ParseFloat(mapFromNATSMessage[columnNameFromDataTypesInRecipe].(string), 64)

                            if err != nil {
                                fmt.Println("ERROR -->", err)
                            }
                            mapWithCorrectDataTypes[columnNameFromDataTypesInRecipe] = convertedFloat

                            fmt.Println("TYPE -->", reflect.TypeOf(mapWithCorrectDataTypes[columnNameFromDataTypesInRecipe]))
                        }
                    } else {
                        //If column not found in the recipe, format as a string
                        mapWithCorrectDataTypes[natsMessageColumn] = natsMessageColumnValue.(string)
                    }
                }
            }

从最后一行开始，我为 float64s 输入了一条打印语句，以检查映射中此键的数据类型是否正确，并且它通过了此测试!

我的问题是:如果 map 中的数据类型设置正确，为什么本地图作为文档插入 MongoDB 时， float 和整数设置为字符串？!

到目前为止我尝试了什么:

将映射编码和解码为接口(interface)，然后插入记录:

        jsonVersionOfMap, err := json.Marshal(mapWithCorrectDataTypes)

        if err != nil {
            fmt.Println("ERROR -->", err)
        }

        var interfaceForJSON interface{}

        json.Unmarshal(jsonVersionOfMap, &interfaceForJSON)

        fmt.Println("JSON -->", interfaceForJSON)
        err = mongoConnection.Insert(interfaceForJSON)

        if err != nil {
            fmt.Println("Error inserting MongoDB documents", err)
        }

我在这里错过了什么？

查看格式不正确的数据的结果:

最佳答案

这可能不是解决办法。但是我已经解决了我一直遇到的问题。我通过 NATS 使用发布者和订阅者。之前我创建了一个包含所有数据的 map ，然后将其作为消息发送出去，然后订阅者从消息中获取 map ，并处理数据类型(在订阅者端)

为了解决我遇到的问题，我改为在发布商端格式化 map 值。因此，我将检查数据类型的代码移到了 NATS 发布者，而不是处理传入消息的代码

我知道这不是一个理想的解决方案，但如果您正在使用 NATS 并发现您遇到了同样的问题。试试这个

关于json - 将 JSON 或映射从 map[string]interface{} 插入到 MongoDB 集合将 int 和 float 设置为字符串，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/54748463/