将 Google Cloud Pub/Sub 负载映射为 Golang 中的 LogEntry 对象

哈喽！大家好，很高兴又见面了，我是golang学习网的一名作者，今天由我给大家带来一篇《将 Google Cloud Pub/Sub 负载映射为 Golang 中的 LogEntry 对象》，本文主要会讲到等等知识点，希望大家一起学习进步，也欢迎大家关注、点赞、收藏、转发! 下面就一起来看看吧！

我创建了一个日志路由器接收器以将日志导出到 Pub/Sub。 我的 Golang 应用程序应该使用 Google 客户端库 (Golang) 通过专用订阅来使用来自此 Pub/Sub 的消息。

订阅上收到的消息是 LogEntry 对象的 JSON 表示形式。

问题： 如何将 JSON 解组为有用的 Golang 对象？

• 我的第一次尝试是将 JSON 解组为 Entry 对象。尝试失败，因为该对象没有字段的 JSON 映射，特别是 textPayload JSON 字段未解组
• 第二次尝试是将 JSON 解组为 LogEntry 对象。该对象似乎符合定义，但其主要用途是 protobufs（而不是 JSON）。特别是当我尝试将 LogEntry JSON 解组到其中时，出现以下错误

无法将字符串解组到 ltype.LogSeverity 类型的 Go 结构字段 LogEntry.severity

正确答案

如果您收到有关 protopayload 或 timestamppb.timestamp 的错误，它可能是协议缓冲区的 json 表示形式。要在 go 中编组/解组协议缓冲区，您应该使用 protojson 包。示例：

import (
    ... omitted ...

    _ "google.golang.org/genproto/googleapis/cloud/audit"
    logging "google.golang.org/genproto/googleapis/logging/v2"
    "google.golang.org/protobuf/encoding/protojson"
)

func handlerLogEntry(w http.ResponseWriter, r *http.Request) {
    var le logging.LogEntry
    body, err := ioutil.ReadAll(r.Body)
    if err != nil {
        http.Error(w, "Bad HTTP Request", http.StatusBadRequest)
        log.Printf("handlerLogEntry ReadAll error: %", err)
        return
    }
    if err := protojson.Unmarshal(body, &le); err != nil {
        http.Error(w, "Bad HTTP Request", http.StatusBadRequest)
        log.Printf("handlerLogEntry Unmarshal error: %", err)
        return
    }
    s := fmt.Sprintf("handlerLogEntry: %#v", le)
    log.Printf(s)
    fmt.Fprintln(w, s)
}

终于介绍完啦！小伙伴们，这篇关于《将 Google Cloud Pub/Sub 负载映射为 Golang 中的 LogEntry 对象》的介绍应该让你收获多多了吧！欢迎大家收藏或分享给更多需要学习的朋友吧~golang学习网公众号也会发布Golang相关知识，快来关注吧！