Warm tip: This article is reproduced from serverfault.com, please click

go-如何接收发布时间

(go - How to receive publishTime)

发布于 2020-11-27 22:10:32

我在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 -

有什么建议么?

Questioner
Neal S
Viewed
0
guillaume blaquiere 2020-11-28 21:38:35

它没有很好的文档记录,但确实如此。

当你直接推送功能与使用HTTP触发功能的推送订阅进行比较时事件结构有所不同

相反,你可以通过事件元数据的事件ID和时间戳属性访问publishTime和messageId。该元数据可通过上下文对象访问,该上下文对象在调用时将传递给你的函数。

Go背景上下文描述中,对要使用的包(函数/元数据)进行了解释,以获取上下文值


这里如何实现这一目标

  1. 执行一个 go get cloud.google.com/go
  2. 在代码中使用此依赖关系,并从上下文中获取消息元数据
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
}