0

次のjsonを非整列化するためのデータ構造を作成するのに苦労しています:

{
    "asks": [
        ["2.049720", "183.556", 1576323009],
        ["2.049750", "555.125", 1576323009],
        ["2.049760", "393.580", 1576323008],
        ["2.049980", "206.514", 1576322995]
    ],
    "bids": [
        ["2.043800", "20.691", 1576322350],
        ["2.039080", "755.396", 1576323007],
        ["2.036960", "214.621", 1576323006],
        ["2.036930", "700.792", 1576322987]
    ]
}

インターフェイスで次の構造体を使用する場合、問題はありません。

type OrderBook struct {
    Asks [][]interface{} `json:"asks"`
    Bids [][]interface{} `json:"bids"`
}

しかし、私はより厳密なタイピングが必要なので、試してみました:

type BitfinexOrderBook struct {
    Pair string            `json:"pair"`
    Asks [][]BitfinexOrder `json:"asks"`
    Bids [][]BitfinexOrder `json:"bids"`
}

type BitfinexOrder struct {
    Price     string
    Volume    string
    Timestamp time.Time
}

しかし、残念ながら私は成功しませんでした。

これは、注文書を取得するために Kraken API を解析するために使用したコードです。

// loadKrakenOrderBook is delegated to load the data related to pairs info
func loadKrakenOrderBook(data []byte) (datastructure.BitfinexOrderBook, error) {
    var err error

    // Creating the maps for the JSON data
    m := map[string]interface{}{}
    var orderbook datastructure.BitfinexOrderBook

    // Parsing/Unmarshalling JSON
    err = json.Unmarshal(data, &m)

    if err != nil {
        zap.S().Debugw("Error unmarshalling data: " + err.Error())
        return orderbook, err
    }

    a := reflect.ValueOf(m["result"])

    if a.Kind() == reflect.Map {
        key := a.MapKeys()[0]
        log.Println("KEY: ", key)
        strct := a.MapIndex(key)
        log.Println("MAP: ", strct)
        m, _ := strct.Interface().(map[string]interface{})
        log.Println("M: ", m)
        data, err := json.Marshal(m)
        if err != nil {
            zap.S().Warnw("Panic on key: ", key.String(), " ERR: "+err.Error())
            return orderbook, err
        }
        log.Println("DATA: ", string(data))
        err = json.Unmarshal(data, &orderbook)
        if err != nil {
            zap.S().Warnw("Panic on key: ", key.String(), " during unmarshal. ERR: "+err.Error())
            return orderbook, err
        }
        return orderbook, nil

    }
    return orderbook, errors.New("UNABLE_PARSE_VALUE")
}

テストに使用するデータは次のとおりです。

{
    "error": [],
    "result": {
        "LINKUSD": {
            "asks": [
                ["2.049720", "183.556", 1576323009],
                ["2.049750", "555.125", 1576323009],
                ["2.049760", "393.580", 1576323008],
                ["2.049980", "206.514", 1576322995]
            ],
            "bids": [
                ["2.043800", "20.691", 1576322350],
                ["2.039080", "755.396", 1576323007],
                ["2.036960", "214.621", 1576323006],
                ["2.036930", "700.792", 1576322987]
            ]
        }
    }
}

編集

注bids: 入力で受け取るデータは、 andの配列ではなく、投稿した最新の json ですasks。

@chmike によって提案されたソリューションを統合しようとしました。残念ながら、データは私が投稿した最新のjsonであるため、いくつかの前処理が必要です。

asksとに関連するjsonデータを抽出するために、次のようにコードに変更しましたbids。

func order(data []byte) (datastructure.BitfinexOrderBook, error) {
    var err error

    // Creating the maps for the JSON data
    m := map[string]interface{}{}
    var orderbook datastructure.BitfinexOrderBook
    // var asks datastructure.BitfinexOrder
    // var bids datastructure.BitfinexOrder
    // Parsing/Unmarshalling JSON
    err = json.Unmarshal(data, &m)

    if err != nil {
        zap.S().Warn("Error unmarshalling data: " + err.Error())
        return orderbook, err
    }

    // Extract the "result" json
    a := reflect.ValueOf(m["result"])

    if a.Kind() == reflect.Map {
        key := a.MapKeys()[0]
        log.Println("KEY: ", key)
        log.Println()
        strct := a.MapIndex(key)
        log.Println("MAP: ", strct)
        m, _ := strct.Interface().(map[string]interface{})
        log.Println("M: ", m)
        log.Println("Asks: ", m["asks"])
        log.Println("Bids: ", m["bids"])

        // Here i retrieve the asks array
        asks_data, err := json.Marshal(m["asks"])
        log.Println("OK: ", err)
        log.Println("ASKS: ", string(asks_data))
        var asks datastructure.BitfinexOrder
        // here i try to unmarshal the data into the struct
        asks, err = UnmarshalJSON(asks_data)
        log.Println(err)
        log.Println(asks)

    }
    return orderbook, errors.New("UNABLE_PARSE_VALUE")
}

残念ながら、次のエラーが表示されます。

json: cannot unmarshal array into Go value of type json.Number

4

2 に答える 2

1

reflex を使用して自分のやり方をハックしたり、独自のパーサーを作成したりすることもできますが、最も効率的な方法はjson.Unmarshaler.

ただし、いくつかの問題が残っています。

  1. その中の要素だけでなく、 ajson arrayを に変換しているので、 と である必要があります。structinterface{}Asks []BitfinexOrderBids []BitfinexOrder

  2. BitfinexOrderBook構造体をそのデータで機能させるには、構造体をラップする必要があります。これは自明であり、reflex を使用するよりもはるかに簡単です。

  3. デフォルトでは、 a を float64 にjson.Unmarshalアンマーシャリングしますjson numberが、これは を解析するときに適切ではありませんtimestamp。を使用json.NewDecoderしてデコーダーを取得し、 をDecoder.UseNumber使用して文字列を強制的に使用できます。

例えば、

func (bo *BitfinexOrder) UnmarshalJSON(data []byte) error {
    dec := json.NewDecoder(bytes.NewReader(data))
    dec.UseNumber()

    var x []interface{}
    err := dec.Decode(&x)
    if err != nil {
        return errParse(err.Error())
    }

    if len(x) != 3 {
        return errParse("length is not 3")
    }

    price, ok := x[0].(string)
    if !ok {
        return errParse("price is not string")
    }

    volume, ok := x[1].(string)
    if !ok {
        return errParse("volume is not string")
    }

    number, ok := x[2].(json.Number)
    if !ok {
        return errParse("timestamp is not number")
    }
    tint64, err := strconv.ParseInt(string(number), 10, 64)
    if err != nil {
        return errParse(fmt.Sprintf("parsing timestamp: %s", err))
    }

    *bo = BitfinexOrder{
        Price:     price,
        Volume:    volume,
        Timestamp: time.Unix(tint64, 0),
    }
    return nil
}

およびメイン関数 (構造体のラップ):

func main() {
    x := struct {
        Result struct{ LINKUSD BitfinexOrderBook }
    }{}
    err := json.Unmarshal(data, &x)
    if err != nil {
        log.Fatalln(err)
    }

    bob := x.Result.LINKUSD
    fmt.Println(bob)
}

遊び場リンク: https://play.golang.org/p/pC124F-3M_S .

注: プレイグラウンド リンクはヘルパー関数を使用してエラーを作成します。ヘルパー関数に名前を付けるNewErrInvalidBitfinexOrderか、エラーの名前を変更するのが最善であると主張する人もいるかもしれません。それはこの質問の範囲ではありません。タイピングのために、今のところ短い名前のままにします。

于 2019-12-14T16:17:31.150 に答える