JSON вложенная структура golang

Question

Я пытаюсь создать адаптер nats к mongodb с golang и не выяснил, как построить для этого структурирующий элемент json

[
   [
      1580946420.000000,
      {
         "tag":"logger.example",
         "log":"2020-02-05T23:47:00+0000 INFO takes the value and converts it to string.",
         "container_id":"15fe6ca47aaa88d5d5a9936abaa1495e62d568eaede8a3860beda48e1404c0f5",
         "container_name":"/nats-mongo_log-generator_1",
         "source":"stdout"
      }
   ],
   [
      1580946423.000000,
      {
         "tag":"logger.example",
         "container_id":"15fe6ca47aaa88d5d5a9936abaa1495e62d568eaede8a3860beda48e1404c0f5",
         "container_name":"/nats-mongo_log-generator_1",
         "source":"stdout",
         "log":"2020-02-05T23:47:03+0000 INFO takes the value and converts it to string."
      }
   ],
  ...
]

Answer 1

Вы можете использовать структуру для внутреннего объекта:

type InnerObj struct {
   Tag string `json:"tag"`
   ContainerID string `json:"container_id"`
   ContainerName string `json:"container_name"`
   Source string `json:"stdout"`
   Log string `json:"log"`
}

Остальное, вы не можете сделать, используя структуры.

Чтобы сгенерировать, вы можете построить дерево с использованием массивов, например:

[]interface{} { []interface{} {1580946420.000000,InnerObj{...}},
{1580946423.000000, InnerObj{...}}}

С помощью разбора это не так просто, используя структуры. У вас есть несколько вариантов:

• Разобрать на interface{} и работать над ним
• Использовать многопроходный подход

Многопроход проще в реализации:

var arr [][]json.RawMessage
json.Unmarshal(data,&arr)

Это должно дать вам каждый внутренний массив в виде двумерного необработанного json сообщения. Затем вы можете использовать декодер для работы с каждым:

for _,arr1:=range arr {
   for _,arr2:=range arr1 {
     var data InnerObj
     var number float64
     dec:=json.NewDecoder(bytes.NewReader(msg))
     if msg[0]=='{' {
        dec.Decode(&data)
     } else {
        dec.Decode(&number)
     }
  }
}

Вы, конечно, можете использовать Decoder полностью и также проанализировать файл самостоятельно.

Answer 2

Спасибо за советы:)

Я наконец-то решил эту проблему.

type CLog struct {
    Tag           string `json:"tag" bson:"tag"`
    Log           string `json:"log" bson:"log"`
    ContainerID   string `json:"container_id" bson:"container_id"`
    ContainerName string `json:"container_name" bson:"container_name"`
    Source        string `json:"source" bson:"source"`
}

var arr [][]json.RawMessage
        json.Unmarshal([]byte(string(m.Data)), &arr)

        // ? Loglar
        for _, arr1 := range arr {
            var logum CLog

            // ? Tek log
            dec := json.NewDecoder(bytes.NewReader(arr1[1]))
            dec.Decode(&logum)

            sugar.Debug(logum)
            _, err := collection.InsertOne(ctx, bson.D{})
            if err != nil {
                //sugar.Debug(err)
                //sugar.Debug(res)
            }
            // id := res.InsertedID
            // sugar.Debug(id)
        }