直接发布事件

使用集合让一切井井有条 根据您的偏好保存内容并对其进行分类。

gcloud

1. 打开终端。

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

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

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

   或：
   gcloud beta 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 beta 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 beta 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 方法。

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

• 公交车的完整资源名称，格式为 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\"}"
}

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

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

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"

@'
{
"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

$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

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

200 OK

{}