我在Go中有一个GC函数,它是由对某个主题的pubsub push订阅触发的。我正在尝试接收publishTime,但它似乎没有被填充。
规范说的是字符串(时间戳格式),但是,我的模型中的该字段为空。除publishTime外,其他所有信息均已填充。
type PubSubMessageModel struct {
Data []byte `json:"data"`
Attributes map[string]string `json:"attributes"`
PublishTime string `json:"publishTime"`
}
只是尝试记录该属性;
log.Info().Msgf("Publish Time is - %s\n", m.PublishTime)
结果为空字符串:
Publish Time is -
有什么建议么?
它没有很好的文档记录,但确实如此。
当你直接推送功能与使用HTTP触发功能的推送订阅进行比较时,事件结构有所不同。
相反,你可以通过事件元数据的事件ID和时间戳属性访问publishTime和messageId。该元数据可通过上下文对象访问,该上下文对象在调用时将传递给你的函数。
在Go的背景上下文描述中,对要使用的包(函数/元数据)进行了解释,以获取上下文值
这里如何实现这一目标
go get cloud.google.com/go
import (
"cloud.google.com/go/functions/metadata"
"context"
"log"
)
type PubSubMessage struct {
Data []byte `json:"data"`
}
// HelloPubSub consumes a Pub/Sub message.
func HelloPubSub(ctx context.Context, m PubSubMessage) error {
meta,err := metadata.FromContext(ctx)
if err != nil {
log.Println(err)
return err
}
log.Printf("publishTime, %s", meta.Timestamp)
log.Printf("messageId, %s", meta.EventID)
log.Printf("Type, %s", meta.EventType)
log.Printf("Resource, %s", meta.Resource)
return nil
}