有没有任何方法可以跟踪多个谷歌存储桶中的文件信息(大小、名称、存储桶位置、创建/更新时间戳)

Question

我可以使用以下代码在单个存储桶中跟踪文件入口。但我想在谷歌云上跟踪进入我项目不同桶的所有文件。。有办法吗？

def hello_gcs(event, context):
"""Triggered by a change to a Cloud Storage bucket.
Args:
event (dict): Event payload.
context (google.cloud.functions.Context): Metadata for the event.
"""
import os
from google.cloud import bigquery
BQ = bigquery.Client()
table_id = 'xx.DW_STAGE.Bucket_Monitor'
table = BQ.get_table(table_id)

bucket=event['bucket']
file_nm=event['name']
create_ts=event['timeCreated']
update_ts=event['updated']
size=event['size']
contentType=event['contentType']
crc32c=event['crc32c']
etag=event['etag']
generation=event['generation']
file_id=event['id']
kind=event['kind']
md5Hash=event['md5Hash']
medialink=event['mediaLink']
metageneration=event['metageneration']
selfLink=event['selfLink']
storageClass=event['storageClass']
timeStorageClassUpdated=event['timeStorageClassUpdated']
errors = BQ.insert_rows(table, [(bucket,file_nm,create_ts,update_ts,size,contentType,crc32c,etag,generation,file_id,kind,md5Hash,medialink,metageneration,selfLink,storageClass,timeStorageClassUpdated)])  # Make an API request.
if errors == []:
print("New rows have been added.")
else:
print("Encountered errors while inserting rows: {}".format(errors))

Answer 1

也许你会对Pub/Sub感兴趣。此机制在下面由云功能存储触发器使用(此处有说明(。

对于您的每个bucket，您可以在同一主题中创建Pub/Sub通知(您可以在此处找到如何创建通知(。每个通知都可以具有属性和有效载荷，其中包含有关更改对象的信息。

这样的通知可以用作类似于您的云功能的触发器。