使用 Go 解组 PubSub 请求数据 []bytes

Question

我有一个从 Google PubSub 请求接收数据的端点。根据这个 repo，对象是这样的：

type pushRequest struct {

    Message struct {

        Attributes map[string]string

        Data       []byte

        ID         string `json:"message_id"`

    }

    Subscription string

}

数据字段的格式一致，如下所示：

type Data struct {

    Key  string                 `json:"key"`

    Body string                 `json:"body"`

    Meta map[string]interface{} `json:"meta"`

}

我可以明显地用这样的方式解组 JSON 请求：

f := &pushRequest{}

json.Unmarshal(msg, &f)

剩下的 []bytes 字段。根据文档，我可以做这样的事情来转换为字符串

messages = append(messages, string(f.Message.Data))

这没有帮助，因为我需要它作为一个结构。

我可以再次解组数组：

var m Data

json.Unmarshal(f.Message.Data, &m)

尝试将 pushRequest 结构中的字段类型更改为 Data 但没有成功。空白的...

有没有一种方法可以一次性打开包装？做两次似乎很荒谬。

如果很明显，我就是看不到！

Answer 1

decoder := json.NewDecoder(r.Body)psmsg := &PushRequest{}decoderErr := decoder.Decode(&psmsg)if decoderErr != nil {    // Error...     return}data := Data{}unmarshalErr := json.Unmarshal([]byte(string(psmsg.Message.Data)), &data)if unmarshalErr != nil {    // Error...    return}

Answer 2

这是我的云功能的一个片段，它用作发布/订阅推送端点。关键是您首先必须使用PushRequest结构解码主体。接下来，您可以将消息数据转换为结构。根据文档，其中的Data字段Message是 base-64 编码的字符串，因此您必须先对其进行解码。type PushRequest struct {    Message      pubsub.PubsubMessage `json:"message"`    Subscription string               `json:"subscription"`}type Example struct {    ID string `json:"id" firestore:"id"`}func HTTPEndpoint(w http.ResponseWriter, r *http.Request) {    var pr common.PushRequest    if err := json.NewDecoder(r.Body).Decode(&pr); err != nil {        log.Fatalf("Could not decode body: %v", err)        return    }    data, err := base64.StdEncoding.DecodeString(pr.Message.Data)    if err != nil {        log.Fatalf("Base64: %v", err)        return    }    var example Example    if err := json.Unmarshal(data, &example); err != nil {        log.Fatalf("Json: %v", err)        return    }    // Do something useful with the struct}