向 HTTP Google Cloud 函数发送消息

Question

我想将message 发送到HTTP triggered Google Cloud Function。具体来说，我想在文件版本发生变化时告诉函数，以便函数将新版本的文件加载到内存中。

我考虑过更新environment variable 作为发送该消息的一种方式，但运行update-env-vars 并不是那么简单，因为这需要在函数项目的上下文中完成。

我还想过使用database，这对于单个变量来说听起来太多了，而在当前版本的存储中使用简单的text file，这听起来太少了。还有什么想法吗？

Answer 1

根据 cmets 部分的对话，我认为实现您所寻找的最佳方法是触发 PubSub 的 gcs 通知。

gsutil notification create -t TOPIC_NAME -f json gs://BUCKET_NAME

PubSub 将根据事件类型收到通知，我相信这将取决于您认为文件的新版本（元数据更改？将创建新 blob？）

基本上，您可以在上面的命令中传递 -e 标志来指示事件类型：

OBJECT_FINALIZE 当一个新对象（或一个新生成的 现有对象）在存储桶中成功创建。这包括 复制或重写现有对象。上传失败不会 触发此事件。

OBJECT_METADATA_UPDATE 当已有对象的元数据时发送 变化。

这意味着，GCS 中的任何文件上传或元数据更改都会触发 PubSub，从而触发您的 Cloud Function。从 PubSub 中提取消息的函数示例

def hello_pubsub(event, context):
    
    import base64

    print("""This Function was triggered by messageId {} published at {} to {}
    """.format(context.event_id, context.timestamp, context.resource["name"]))

    if 'data' in event:
        name = base64.b64decode(event['data']).decode('utf-8')
    else:
        name = 'World'
    print('Hello {}!'.format(name))

参考文件：

https://cloud.google.com/storage/docs/pubsub-notifications https://cloud.google.com/functions/docs/calling/pubsub#functions_calling_pubsub-python