插入 JSON 或从 map[string]interface{} 到 MongoDB collection 的映射将整数和浮点数设置为字符串

Question

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

我的系统正在使用消息服务 NATS 在订阅者和发布者之间发送地图。订户获取收到的地图，并将其作为文档插入 MongoDB collection

我遇到的问题是浮点数和整数作为字符串插入！

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

字符串列："string"、
整数列："int"

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

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 的打印语句，以检查映射中此键的数据类型是否正确，并通过了此测试！

我的问题是：如果在地图中正确设置了数据类型，为什么当地图作为文档插入 MongoDB 时，浮点数和整数设置为字符串?!

到目前为止我尝试过的：

将映射编组和解组为接口，然后插入记录：

        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)
        }

我在这里错过了什么？

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

Answer 1

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

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

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

插入 JSON 或从 map[string]interface{} 到 MongoDB collection 的映射将整数和浮点数设置为字符串

Inserting JSON or a map from map[string]interface{} to MongoDB collection sets ints and floats as strings

json

go

maps

mgo