Ereignisse direkt veröffentlichen

gcloud

1. Öffnen Sie ein Terminalfenster.

2. Sie können Ereignisse in einem Bus mit dem Befehl gcloud beta eventarc message-buses publish veröffentlichen. Beispiel:

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

   oder:
   gcloud beta eventarc message-buses publish BUS_NAME \
       --json-message=JSON_MESSAGE

   oder:
   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

   Ersetzen Sie Folgendes:

   • BUS_NAME: die ID oder voll qualifizierte Kennzeichnung des Busses, in dem das Ereignis veröffentlicht werden soll.

   Sie dürfen nur eine der folgenden Optionen verwenden:

   • AVRO_MESSAGE: Die Ereignismeldung im Avro-Format gemäß dieser Spezifikation.
   • JSON_MESSAGE: die Ereignisnachricht im JSON-Format gemäß dieser Spezifikation.
   • DATA_PAYLOAD: die Daten eines veröffentlichten Ereignisses.

   Wenn Sie das Flag --event-data verwenden, müssen Sie auch Folgendes verwenden:

   • EVENT_ID: die Ereigniskennung. Ereignisproduzenten müssen dafür sorgen, dass source + id für jedes einzelne Ereignis eindeutig ist.
   • EVENT_SOURCE: Die Ereignisquelle eines veröffentlichten Ereignisses.
   • EVENT_TYPE: Der Ereignistyp, der sich auf das ursprüngliche Ereignis bezieht.

   Wenn Sie das Flag --event-data verwenden, können Sie optional Folgendes verwenden:

   • EVENT_ATTRIBUTE: die Attribute eines veröffentlichten Ereignisses. Sie können das Flag --event-attributes wiederholen, um weitere Attribute hinzuzufügen.

     Ereignisse können beliebig viele zusätzliche benutzerdefinierte CloudEvents-Attribute mit unterschiedlichen Namen (auch als Erweiterungsattribute bezeichnet) enthalten.

Beispiele:

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

Verwenden Sie zum Veröffentlichen eines Ereignisses in einem Bus die Methode projects.locations.messageBuses.publish.

Ersetzen Sie diese Werte in den folgenden Anfragedaten:

• Der vollständige Ressourcenname des Busses im Format projects/PROJECT_ID/locations/LOCATION/messageBuses/BUS_NAME

  Ersetzen Sie Folgendes:

  • PROJECT_ID: die Google Cloud Projekt-ID für das Bus-Projekt.
  • LOCATION: die Region, in der der Bus bereitgestellt wird, z. B. us-central1.
  • BUS_NAME: Der Name des Busses, an den das Ereignis gesendet werden soll.
• SPEC_VERSION: Die Version der CloudEvents-Spezifikation, die für das Ereignis verwendet wird, z. B. 1.0.
• EVENT_TYPE: Der Ereignistyp, der sich auf das ursprüngliche Ereignis bezieht.
• EVENT_SOURCE: die Ereignisquelle eines veröffentlichten Ereignisses.
• EVENT_ID: die Ereigniskennung. Feedersteller müssen dafür sorgen, dass source + id für jedes einzelne Event eindeutig ist.
• CONTENT_TYPE (optional): Der Inhaltstyp des data-Werts. Wenn ein Ereignis im JSON-Format kein datacontenttype-Attribut hat, wird davon ausgegangen, dass die Daten ein JSON-Wert sind, der dem Medientyp application/json entspricht.
• DATA_PAYLOAD (optional): Die Ereignisnutzlast, die in das durch datacontenttype angegebene Media-Format codiert ist und dataschema entspricht, wenn diese Attribute vorhanden sind.

JSON-Text der Anfrage:

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

Wenn Sie die Anfrage senden möchten, maximieren Sie eine der folgenden Optionen:

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

Bei Erfolg gibt der Server den HTTP-Statuscode 200 OK und den leeren Antworttext im JSON-Format zurück:

200 OK

{}