直接发布事件

高级

您可以使用 Google Cloud CLI 或通过向 Eventarc Publishing REST API 发送请求，以支持的格式将 CloudEvents 事件直接发布到 Eventarc 高级总线。您还可以使用 Eventarc 客户端库，通过支持的语言访问 Eventarc API。

准备工作

如果尚未启用，请启用 Eventarc API 和 Eventarc Publishing API。

gcloud services enable eventarc.googleapis.com eventarcpublishing.googleapis.com

直接发布

您直接发布的事件消息必须符合 CloudEvents 规范。

gcloud

1. 打开终端。

2. 您可以使用 gcloud eventarc message-buses publish 命令将事件发布到总线。例如：

   gcloud eventarc message-buses publish BUS_NAME \
       --avro-message=AVRO_MESSAGE

   或：
   gcloud eventarc message-buses publish BUS_NAME \
       --json-message=JSON_MESSAGE

   或：
   gcloud eventarc message-buses publish BUS_NAME \
       --event-data=DATA_PAYLOAD \
       --event-id=EVENT_ID \
       --event-source=EVENT_SOURCE \
       --event-type=EVENT_TYPE \
       --event-attributes=EVENT_ATTRIBUTE

   替换以下内容：

   • BUS_NAME：要向其发布事件的总线的 ID 或完全限定标识符。

   您只能使用以下其中一项：

   • AVRO_MESSAGE：根据此规范，采用 Avro 格式的事件消息。
   • JSON_MESSAGE：根据此规范，采用 JSON 格式的事件消息。
   • DATA_PAYLOAD：已发布事件的数据。

   如果使用 --event-data 标志，您还必须使用以下标志：

   • EVENT_ID：活动标识符。事件提供方必须确保 source + id 对于每个不同事件都是唯一的。
   • EVENT_SOURCE：已发布事件的事件源。
   • EVENT_TYPE：与原始事件相关的事件类型。

   如果使用 --event-data 标志，您可以选择性地使用以下标志：

   • EVENT_ATTRIBUTE：已发布事件的属性。 您可以重复使用 --event-attributes 标志来添加更多属性。

     请注意，事件可能包含任意数量的其他具有不同名称的自定义 CloudEvents 属性（也称为扩展属性）。

示例：

gcloud eventarc message-buses publish my-bus \
    --event-data='{"key": "hello-world-data"}' \
    --event-id=hello-world-id-1234 \
    --event-source=hello-world-source \
    --event-type=hello-world-type \
    --event-attributes="datacontenttype=application/json"

gcloud eventarc message-buses publish my-bus --json-message='{
    "specversion" : "1.0",
    "type" :"com.example.someevent",
    "source" : "google.cloud.storage.object.v1.finalized",
    "id" : "A234-1234-1234",
    "time" : "2024-04-05T17:31:00Z",
    "bucket" : "bucketName",
    "datacontenttype" : "application/json",
    "data":{"key": "value"}
}'

REST API

如需将事件发布到总线，请使用 projects.locations.messageBuses.publish 方法。

注意： 在请求正文的 ProtoMessage 中，只有当载荷是特定的 CloudEvent 消息类型时，protoData 字段才能按预期发挥作用，而不能用于任意协议缓冲消息。对于任何其他协议缓冲区类型，您都必须将 proto 消息序列化为字节，并改用 binaryData 字段。

在使用任何请求数据之前，请先进行以下替换：

• 总线的完整资源名称，格式为 projects/PROJECT_ID/locations/LOCATION/messageBuses/BUS_NAME

  替换以下内容：

  • PROJECT_ID：总线项目的 Google Cloud项目 ID。
  • LOCATION：部署总线的区域，例如 us-central1。
  • BUS_NAME：要向其发布事件的总线的名称。
• SPEC_VERSION：事件使用的 CloudEvents 规范版本，例如 1.0。
• EVENT_TYPE：与原始事件相关的事件类型。
• EVENT_SOURCE：已发布事件的事件源。
• EVENT_ID：事件标识符。 提供方必须确保 source + id 对于每个不同事件都是唯一的。
• CONTENT_TYPE（可选）：data 值的内容类型。如果 JSON 格式的事件没有 datacontenttype 属性，则假定该数据是符合 application/json 媒体类型的 JSON 值。
• DATA_PAYLOAD（可选）：编码为 datacontenttype 指定的媒体格式并遵循 dataschema 的事件载荷（如果存在这些属性）。

请求 JSON 正文：

{
"jsonMessage":
  "{\"specversion\":\"SPEC_VERSION\",
  \"type\":\"EVENT_TYPE\",
  \"source\":\"EVENT_SOURCE\",
  \"id\":\"EVENT_ID\",
  \"datacontenttype\":\"CONTENT_TYPE\",
  \"data\":\"DATA_PAYLOAD\"}"
}

如需发送您的请求，请展开以下选项之一：

curl（Linux、macOS 或 Cloud Shell）

注意：以下命令假定您已使用您的用户账号通过运行 gcloud init 或 gcloud auth login 登录 gcloud CLI，或者使用了 Cloud Shell，这会使您自动登录 gcloud CLI。您可以运行 gcloud auth list 来检查当前活跃的账号。

将请求正文保存在名为 request.json 的文件中。在终端中运行以下命令，在当前目录中创建或覆盖此文件：

cat > request.json << 'EOF'
{
"jsonMessage":
  "{\"specversion\":\"SPEC_VERSION\",
  \"type\":\"EVENT_TYPE\",
  \"source\":\"EVENT_SOURCE\",
  \"id\":\"EVENT_ID\",
  \"datacontenttype\":\"CONTENT_TYPE\",
  \"data\":\"DATA_PAYLOAD\"}"
}
EOF

然后，执行以下命令以发送 REST 请求：

curl -X POST \
     -H "Authorization: Bearer $(gcloud auth print-access-token)" \
     -H "Content-Type: application/json; charset=utf-8" \
     -d @request.json \
     "https://eventarcpublishing.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/messageBuses/BUS_NAME:publish"

PowerShell (Windows)

注意：以下命令假定您已使用您的用户账号通过运行 gcloud init 或 gcloud auth login 登录 gcloud CLI。您可以运行 gcloud auth list 来检查当前活跃的账号。

将请求正文保存在名为 request.json 的文件中。在终端中运行以下命令，在当前目录中创建或覆盖此文件：

@'
{
"jsonMessage":
  "{\"specversion\":\"SPEC_VERSION\",
  \"type\":\"EVENT_TYPE\",
  \"source\":\"EVENT_SOURCE\",
  \"id\":\"EVENT_ID\",
  \"datacontenttype\":\"CONTENT_TYPE\",
  \"data\":\"DATA_PAYLOAD\"}"
}
'@  | Out-File -FilePath request.json -Encoding utf8

然后，执行以下命令以发送 REST 请求：

$cred = gcloud auth print-access-token
$headers = @{ "Authorization" = "Bearer $cred" }

Invoke-WebRequest `
    -Method POST `
    -Headers $headers `
    -ContentType: "application/json; charset=utf-8" `
    -InFile request.json `
    -Uri "https://eventarcpublishing.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/messageBuses/BUS_NAME:publish" | Select-Object -Expand Content

APIs Explorer（浏览器）

复制请求正文并打开方法参考页面。APIs Explorer 面板会在页面右侧打开。您可以与此工具进行交互以发送请求。 将请求正文粘贴到此工具中，填写任何其他必填字段，然后点击执行。

如果请求成功，服务器将返回一个 HTTP 200 OK 状态代码以及 JSON 格式的空响应正文：

200 OK

{}

后续步骤

• 发布来自 Google 来源的事件
• 转换已接收事件
• 设置已接收事件的格式