google 云 python kubernetes 服务对存储桶写入执行操作

google cloud python kubernetes service performing action on bucket write

我正在尝试编写一些将部署在 kubernetes 上的 python 服务,该服务执行类似于由 google.storage.object.finalize 操作触发的云功能并监听存储桶。本质上,我需要替换使用以下参数创建的云函数:

--trigger-resource YOUR_TRIGGER_BUCKET_NAME 
--trigger-event google.storage.object.finalize

但是我无法在网上找到有关如何执行此操作的任何资源。对于部署在 kubernetes 中的某些 python 脚本,观察对存储桶执行的操作并在将新文件写入其中时执行某些操作的最佳方式是什么?谢谢

您只需在存储桶上启用 pubsub 通知即可发布到 pub/sub 主题:https://cloud.google.com/storage/docs/pubsub-notifications

然后让您 python 应用程序在拉取或推送设置中收听您选择的主题的订阅:https://cloud.google.com/pubsub/docs/pull.