Réorganisation des données JSON non homogènes

Cette enquête se concentre sur la désorganisation efficace des données JSON en exploitant un mécanisme qui permet la désorganisation sélective de sections spécifiques. ou segments. L'objectif est de gérer des structures JSON où la première partie sert de « code » qui détermine le type de données contenues dans la dernière partie.

Imaginez un scénario dans lequel vous disposez de plusieurs structures de données :

type Range struct {
    Start int
    End   int
}

type User struct {
    ID    int
    Pass  int
}

Et votre message JSON comporte un champ "code" qui signale quelles données se trouvent dans le champ "charge utile" :

{
    "Code": 4,
    "Payload": {
        "Start": 1,
        "End": 10
    }
}
{
    "Code": 3,
    "Payload": {
        "ID": 1,
        "Pass": 1234
    }
}

Vous devez désorganiser le champ « charge utile » dans la structure de données appropriée en fonction du champ « code ».

Solution

La clé voici d'utiliser le type json.RawMessage pour retarder le désorganisation du champ "payload" jusqu'à ce que vous connaissiez son type. Par exemple : 

package main

import (
    "encoding/json"
    "fmt"
)

type Message struct {
    Code    int
    Payload json.RawMessage // Delay parsing until we know the code
}

// Unmarshall into appropriate structures based on Code
func unmarshal(m []byte) error {
    var message Message
    err := json.Unmarshal(m, &message)
    if err != nil {
        return err
    }
    switch message.Code {
    case 3:
        var user User
        if err := json.Unmarshal(message.Payload, &user); err != nil {
            return err
        }
        fmt.Printf("Unmarshalled a User: %#v\n", user)
    case 4:
        var range Range
        if err := json.Unmarshal(message.Payload, &range); err != nil {
            return err
        }
        fmt.Printf("Unmarshalled a Range: %#v\n", range)
    default:
        return fmt.Errorf("unknown code: %d", message.Code)
    }
    return nil
}

func main() {
    json1 := []byte(`{"Code": 3, "Payload": {"ID": 1, "Pass": 1234}}`)
    if err := unmarshal(json1); err != nil {
        fmt.Printf("error: %v\n", err)
    }

    json2 := []byte(`{"Code": 4, "Payload": {"Start": 1, "End": 10}}`)
    if err := unmarshal(json2); err != nil {
        fmt.Printf("error: %v\n", err)
    }
}