如何用EventArc同时监听多个Cloud Storage存储桶？

方案1：前缀通配符过滤（统一命名场景适用） #

如果你的客户存储桶有统一命名前缀（比如customer-xxx），EventArc支持用前缀通配符匹配所有符合规则的桶，只需创建一个触发即可覆盖所有目标桶：

gcloud eventarc triggers create storage-events-batch \
--location="$LOCATION" \
--destination-gke-cluster="CLUSTER-NAME" \
--destination-gke-location="$LOCATION" \
--destination-gke-namespace="$NAMSEPACE" \
--destination-gke-service="$SERVICE" \
--destination-gke-path="api/events/receive" \
--event-filters="type=google.cloud.storage.object.v1.finalized" \
--event-filters="bucket=customer-*" \
--service-account=$SERVICEACCOUNT-compute@developer.gserviceaccount.com

注意：通配符仅支持前缀匹配，且所有目标桶需在同一Google Cloud项目下。

方案2：Cloud Audit Logs路由（无统一命名/跨项目场景适用） #

若存储桶命名无规律或分布在不同项目，可通过Cloud Audit Logs间接接收所有桶的finalized事件：

1. 确保所有目标存储桶开启storage.objects.create操作的审计日志（可在Cloud Console存储桶的「权限」>「审计日志」中配置）
2. 创建EventArc触发时监听审计日志事件，无需指定单个桶：

gcloud eventarc triggers create storage-audit-events \
--location="$LOCATION" \
--destination-gke-cluster="CLUSTER-NAME" \
--destination-gke-location="$LOCATION" \
--destination-gke-namespace="$NAMSEPACE" \
--destination-gke-service="$SERVICE" \
--destination-gke-path="api/events/receive" \
--event-filters="type=google.cloud.audit.log.v1.written" \
--event-filters="serviceName=storage.googleapis.com" \
--event-filters="methodName=storage.objects.create" \
--service-account=$SERVICEACCOUNT-compute@developer.gserviceaccount.com

3. 在你的服务中解析事件payload里的resourceName字段（格式为projects/_/buckets/{bucket}/objects/{object}），即可区分事件来自哪个桶。

方案3：批量创建触发脚本（通用兜底方案） #

如果以上方案都不适用，可编写Shell脚本自动遍历所有存储桶并创建触发：

#!/bin/bash
LOCATION="your-location"
CLUSTER_NAME="CLUSTER-NAME"
NAMESPACE="NAMSEPACE"
SERVICE="SERVICE"
SERVICEACCOUNT="your-service-account"

# 遍历当前项目下所有存储桶
for BUCKET in $(gsutil ls | sed 's/gs:\/\/\(.*\)\//\1/'); do
  # 跳过不需要监听的桶（可选）
  if [[ $BUCKET == "exclude-bucket-name" ]]; then
    continue
  fi
  echo "Creating trigger for bucket: $BUCKET"
  gcloud eventarc triggers create storage-events-$BUCKET \
    --location="$LOCATION" \
    --destination-gke-cluster="$CLUSTER_NAME" \
    --destination-gke-location="$LOCATION" \
    --destination-gke-namespace="$NAMESPACE" \
    --destination-gke-service="$SERVICE" \
    --destination-gke-path="api/events/receive" \
    --event-filters="type=google.cloud.storage.object.v1.finalized" \
    --event-filters="bucket=$BUCKET" \
    --service-account=$SERVICEACCOUNT-compute@developer.gserviceaccount.com
done

执行前确保已完成gcloud授权，且账号拥有EventArc和Storage的操作权限。

内容的提问来源于stack exchange，提问作者Christian Schmitt