Memublikasikan peristiwa secara langsung

Tetap teratur dengan koleksi Simpan dan kategorikan konten berdasarkan preferensi Anda.

gcloud

1. Buka terminal.

2. Anda dapat memublikasikan peristiwa ke bus menggunakan perintah gcloud beta eventarc message-buses publish. Contoh:

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

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

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

   Ganti kode berikut:

   • BUS_NAME: ID atau ID yang sepenuhnya memenuhi syarat dari bus tempat peristiwa dipublikasikan.

   Anda hanya boleh menggunakan satu dari hal berikut:

   • AVRO_MESSAGE: pesan peristiwa dalam format Avro sesuai dengan spesifikasi ini.
   • JSON_MESSAGE: pesan peristiwa dalam format JSON sesuai dengan spesifikasi ini.
   • DATA_PAYLOAD: data peristiwa yang dipublikasikan.

   Jika menggunakan flag --event-data, Anda juga harus menggunakan hal berikut:

   • EVENT_ID: ID peristiwa. Produsen peristiwa harus memastikan bahwa source + id bersifat unik untuk setiap peristiwa yang berbeda.
   • EVENT_SOURCE: sumber peristiwa dari peristiwa yang dipublikasikan.
   • EVENT_TYPE: jenis peristiwa yang terkait dengan kejadian asal.

   Jika menggunakan flag --event-data, Anda dapat menggunakan hal berikut secara opsional:

   • EVENT_ATTRIBUTE: atribut peristiwa yang dipublikasikan. Anda dapat mengulangi flag --event-attributes untuk menambahkan lebih banyak atribut.

     Perhatikan bahwa peristiwa dapat menyertakan sejumlah atribut CloudEvents kustom tambahan dengan nama yang berbeda (juga dikenal sebagai atribut ekstensi).

Contoh:

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

Untuk memublikasikan peristiwa ke bus, gunakan metode projects.locations.messageBuses.publish.

Sebelum menggunakan salah satu data permintaan, lakukan penggantian berikut:

• Nama resource lengkap bus dalam format projects/PROJECT_ID/locations/LOCATION/messageBuses/BUS_NAME

  Ganti kode berikut:

  • PROJECT_ID: project ID Google Cloud untuk project bus.
  • LOCATION: region tempat bus di-deploy—misalnya, us-central1.
  • BUS_NAME: nama bus tempat peristiwa akan dipublikasikan.
• SPEC_VERSION: versi spesifikasi CloudEvents yang digunakan peristiwa—misalnya, 1.0.
• EVENT_TYPE: jenis peristiwa yang terkait dengan kemunculan asal.
• EVENT_SOURCE: sumber peristiwa dari peristiwa yang dipublikasikan.
• EVENT_ID: ID peristiwa. Produsen harus memastikan bahwa source + id bersifat unik untuk setiap peristiwa yang berbeda.
• CONTENT_TYPE (opsional): jenis konten nilai data. Jika peristiwa format JSON tidak memiliki atribut datacontenttype, maka data tersebut dianggap sebagai nilai JSON yang sesuai dengan jenis media application/json.
• DATA_PAYLOAD (opsional): payload peristiwa yang dienkode ke dalam format media yang ditentukan oleh datacontenttype dan mematuhi dataschema jika atribut tersebut ada.

Meminta isi JSON:

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

Untuk mengirim permintaan Anda, perluas salah satu opsi berikut:

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

Jika berhasil, server akan menampilkan kode status HTTP 200 OK dan isi respons kosong dalam format JSON:

200 OK

{}