클라우드 pub/sub에서 subscritpion의 메시지를받는 방법?

Question

Cloud Pub/Sub (GCP)의 가입자에게 처리 할 수없는 메시지가 남아 있습니다. pub/sub가 알림없이 일부 메시지를 잃어 버리는 것을 원하지 않습니다.

Cloud Pub/Sub (GCP)에서 deadhead queue를 설정할 수 없다는 것을 알고 있습니다. 그래서 API를 통해 구독 메시지를 볼 수있는 툴이나 배치를 개발하려고하는데, 이는 projects.subscriptions.pull (https://cloud.google.com/pubsub/docs/reference/rest/v1/projects.subscriptions/pull?hl=ja)입니다.

그러나 google-cloud-pubsub : 0.26.0-beta로 API를 호출하는 방법을 모르겠습니다. 또한, scala + play로 배치를 개발 중입니다.

"gcloud beta pubsub subscriptions pull"명령으로 메시지를 얻을 수 있지만 메시지가 잠시 동안 처리되지 않았는지 프로그램에서 확인할 수있는 게시 시간을 얻지 못했습니다.

제발 도와주세요!

Answer 1

Cloud Pub/Sub 클라이언트 라이브러리는 효율적으로 메시지를 수신하도록 설계된 비동기 API를 제공하는 대신 끌어 오기 메소드를 직접 노출하지 않습니다. 이 비동기 API를 사용하여 메시지를받을 수 있습니다. Java documentation은이 API를 사용하여 구독자를 만드는 방법을 보여줍니다. 동기 풀 메소드를 호출 할 특별한 이유가있는 경우 gRPC 기반 라이브러리를 생성해야합니다. 지침은 Service APIs Overview page에서 찾을 수 있습니다.