使用恶意软件 scanner (ClamAV)时的Google云存储桶上传文件验证

    err = sub.Receive(ctx, func(ctx context.Context, m *pubsub.Message) {
                fmt.Println(m.Data)
        m.Ack() // Acknowledge that we've consumed the message.
    })

``` it says this method is not supported for this subscription type...

> gcloud pubsub topics create TOPIC_NAME
> gcloud pubsub subscriptions create SUBSCRIPTION_NAME --topic=TOPIC_NAME
> gcloud storage buckets notifications create gs://BUCKET_NAME --topic=TOPIC_NAME

    err = sub.Receive(ctx, func(ctx context.Context, m *pubsub.Message) {
        event := m.Attributes["eventType"]
        if (event == "OBJECT_FINALIZE") {
            obj := m.Attributes["objectId"]
            fmt.Printf("File %s written successfully.\n", obj)
        }
        m.Ack()
    })

> gcloud pubsub subscriptions create SUBSCRIPTION_NAME \
  --topic=TOPIC_NAME \
  --message-filter 'attributes.eventType = "OBJECT_FINALIZE"'

Go相关问答推荐

gorm插入不支持的数据

运行add. inf，这样我们就可以在app.conf中使用. inf参数了？

获取作为类型参数传递给方法接收方中的类型参数的切片的基础类型

无法读取postman 中的表单数据

该文件位于模块.内，该模块不包含在您的工作区中

「GORM错误」不支持的数据类型：&[]，不正确的模式

当图像是对象数组的元素时，如何显示存储为页面资源的图像？

Go：如何在将 float64 转换为 float32 时判断精度损失

Golang Gin 绑定请求正文 XML 到 Slice

Golang模板无法访问embedFS中的文件

在 docker kill --signal=SIGX 上以这种方式关闭容器内运行的 go 应用程序是否安全？

使用 Golang SQL 驱动程序连接到snowflake

Ginkgo/Gomega panic 测试失败

K8s 算子读取原始数据

Go Fyne 禁用 HSplit 调整大小？

Go 使用 struct 作为接口而不实现所有方法

在 Golang 中使用 OR 条件验证 struct 的两个字段

退格字符在围棋操场中不起作用

无法识别同步错误.使用一次

Golang 将类型 [N]byte 转换为 []byte