使用 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 Datajson.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

}