이벤트 직접 게시

고급

미리보기 — Eventarc Advanced

이 기능에는 서비스별 약관의 일반 서비스 약관 섹션에 있는 'GA 이전 제공 서비스 약관'이 적용됩니다. GA 이전 기능은 '있는 그대로' 제공되며 지원이 제한될 수 있습니다. 자세한 내용은 출시 단계 설명을 참조하세요.

Google Cloud CLI를 사용하거나 Eventarc 게시 REST API에 요청을 전송하여 지원되는 형식으로 CloudEvents 이벤트를 Eventarc 고급 버스에 직접 게시할 수 있습니다. Eventarc 클라이언트 라이브러리를 사용하여 지원되는 언어에서 Eventarc API에 액세스할 수도 있습니다.

메시지는 CloudEvents 사양을 준수해야 합니다.

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-id=1234 \
    --event-type=event-provider.event.v1.eventType \
    --event-source="//event-provider/event/source" \
    --event-data='{"key": "value"}' \
    --event-attributes=attribute1=value

gcloud beta eventarc message-buses publish my-bus --json-message @- << EOF
{
    "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"}
}
EOF

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\"}"
}

요청을 보내려면 다음 옵션 중 하나를 펼칩니다.

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

API 탐색기(브라우저)

요청 본문을 복사하고 메서드 참조 페이지를 엽니다. 페이지 오른쪽에 API 탐색기 패널이 열립니다. 이 도구를 사용하여 요청을 보낼 수 있습니다. 요청 본문을 이 도구에 붙여넣고 다른 필수 필드를 입력한 후 실행을 클릭합니다.

성공하면 서버는 HTTP 200 OK 상태 코드와 JSON 형식의 빈 응답 본문을 반환합니다.

200 OK

{}

다음 단계

• Google 소스의 이벤트 게시
• 수신된 이벤트 변환
• 수신된 이벤트 형식