gcp-pubsub-messages
지정된 시간 동안 구글 클라우드 플랫폼 Pub/Sub에서 메시지를 수신합니다. 수신한 메시지는 확인 응답 처리되어 구독에서 삭제되므로, 같은 구독을 사용하는 수집기는 해당 메시지를 받지 못합니다.
gcp-pubsub-messages [profile=PROFILE] subscription-id=SUBSCRIPTION-ID window=INT{y|mon|w|d|h|m|s}
- profile=PROFILE
- 구글 클라우드 Pub/Sub 접속 프로파일 식별자. 미지정 시 등록된 프로파일이 하나뿐이면 그것을 사용하고, 둘 이상이면 오류가 발생합니다.
- subscription-id=SUBSCRIPTION-ID
- 구글 클라우드 Pub/Sub의 구독 ID. 주제 ID가 아닙니다.
- window=INT{y|mon|w|d|h|m|s}
- 쿼리 시작 시점으로부터 일정 시간 동안 메시지를 수신합니다. s(초), m(분), h(시), d(일), mon(월) 단위로 지정할 수 있습니다. 예를 들면, 10s의 경우 쿼리 시작 후 10초 동안 입력을 수신합니다.
출력 필드
| 필드 | 타입 | 이름 | 설명 |
|---|---|---|---|
| _time | 날짜 | 시각 | 메시지가 게시된 시각 |
| profile | 문자열 | 프로파일 | 구글 클라우드 Pub/Sub 접속 프로파일 식별자 |
| subscription_id | 문자열 | 구독 ID | 수신한 구독 ID |
| msg_id | 문자열 | 메시지 ID | 주제 내에서 유일한 메시지 ID |
| msg | 문자열 | 메시지 | UTF-8 해석된 메시지 문자열 |
| attrs | 맵 | 속성 | 메시지 속성 키-값 목록 |
필요한 권한은 Pub/Sub 구독자(roles/pubsub.subscriber)입니다. 자세한 내용은 액세스 제어 문서를 참고하십시오.
동작 방식
수집기와 동일하게 StreamingPull로 연결을 유지하며 메시지를 수신합니다. window로 지정한 시간이 지나면 연결을 닫고 종료합니다. 방식에 대한 설명은 Pull 구독 문서를 참고하십시오.
수신한 메시지는 즉시 확인 응답 처리되어 구독에서 제거됩니다. 되돌릴 수 없습니다.
사용 시 주의 사항
하나의 구독에 연결된 소비자는 서로 경쟁 관계이며, 각 메시지는 그중 하나에게만 전달됩니다. 따라서 수집기가 동작 중인 구독에서 이 명령어를 실행하면 그만큼 수집 로그가 누락됩니다. 배분 비율은 정해져 있지 않습니다.
구독 내용을 확인할 목적이라면 메시지를 삭제하지 않는 gcp-pubsub-pull을 사용하십시오.