GCP云函数何时确认pub/sub消息？

Question

我有一个从pub/sub消息触发的云函数。此函数从不显式确认源代码中的消息。

那么，如果确认在源代码中从未发生过，这个函数什么时候确认pub/sub消息呢？

 import base64
 def hello_pubsub(event, context):
     pubsub_message = base64.b64decode(event['data']).decode('utf-8')
     print(pubsub_message)
     raise RuntimeError('error in function')

进入test_topic并发布以Go为文本的消息。

test_function日志中将出现错误。但是，只有一个函数调用会出现错误，即使几天后也会出现这种情况。

Answer 1

如果函数顺利完成，则消息为确认。如果函数错误退出，则消息为NACK。

编辑1

我已经测试了一个Go后台功能。您需要使用参数--retry部署云函数，以允许重试错误消息。否则，不会重试这些消息。

null

type PubSubMessage struct {
    Data []byte `json:"data"`

}

func PubsubError(ctx context.Context, m PubSubMessage) error {

    switch string(m.Data) {
    case "ok":
        return nil
    case "error":
        return errors.New("it's an error")
    case "fatal":
        log.Fatal("crash")
    case "exit":
        os.Exit(1)
    }
    return nil
}

以及我是如何部署云功能的

gcloud beta functions deploy --runtime=go113 --trigger-topic=test-topic \
  --source=function --entry-point=PubsubError --region=us-central1 \
  --retry pubsuberror