google-cloud-pubsub

2열

1답변

Google Pub/Sub를 사용할 때 'poison pill'메시지를 어떻게 처리합니까?

예를 들어 Amazon의 SQS를 사용하는 경우 X 재시도 후 삭제되지 않은 메시지 (ack'd)가 별도 처리를 위해 라우팅되는 데드 레터 대기열 (DLQ)을 정의 할 수 있지만 Google Cloud Platform 이 점에 대한 언급이 없습니다.

0열

1답변

Google Pub/Sub 재시도 정책이 필요합니까? 독약을 다루는 법?

Pub/Sub '푸시'모델에서 문서의 내용은 다음과 같습니다. 푸시 엔드 포인트에서 오류 코드가 반환되면 메시지는 지수 백 오프 정책 (최대 10 초)으로 최대 7 일간 재 시도됩니다. 재시도 기간 후에 메시지를 어떻게 처리할지 결정하는 방법이 있습니까? 즉 일부 오류 대기열 등으로 보냅니 까?

0열

1답변

실시간 변환을 pubsub 및 websocket 푸시 클라이언트로

타사 공급자로부터 실시간 데이터를 얻고 변환 한 다음 웹 소켓을 통해 브라우저로 푸시해야합니다. 전체 절차는 브라우저가 데이터를 수신 할 때까지 데이터를받은 시간보다 200ms 이상 걸리지 않아야합니다. 나는 websocket 서버가 구독하고 브라우저에 메시지를 푸시하는 곳으로 pub/sub로 dataflow에 pub/sub를 다시 사용하려고 생각하고 있습

0열

2답변

Google Pub Sub Message .Net 클라이언트에서 발생하는 지연 문제.

Google PubSub에서 계속 메시지를 가져옵니다. 메시지를 가져 오는 데 걸린 시간을 제외하고 모두 좋은 상태로 진행되는 것은 약 12-15 초이며 우리의 경우에는 받아 들일 수 없습니다. 내 CallTiming 설정은 다음과 같은 : public CallSettings GetPullSetting() { CallTiming timi

0열

1답변

Gcp PubSub이 REST 끝점에 메시지를 보내지 않음

Gcp PubSub가 등록 된 끝점으로 메시지를 보내지 않는 문제가 있습니다. 제가 처형 한 단계들을 자세히 이야기하겠습니다. 주, I 앱 엔진 내가 PCF에 내 단순 온천 부팅 응용 프로그램을 배포하고 사용하지 않을하고 (중추적 인 클라우드 파운드리 ... PaaS를가) GCP에서 호스팅 (IaaS를) 단계 : 나는 GCP PubSub 0에 액세스하는 데

0열

1답변

subscription/pull_message_operation_count와 subscription/pull_request_count의 차이

지난 15 일 동안 내 구독이 풀을했는지 확인해야합니다. 어떤 측정 항목을 고려해야합니까? Google pubsub stackdriver 측정 항목에 익숙하지 않으며 혼란 스럽습니다. 는 사람이 나에게 이러한 메트릭의 차이 말할 수 있습니다 가입/pull_message_operation_count을 가입/pull_request_count 가입/pull_ac

0열

1답변

PubSub -> BigQuery - 여러 독립 주제를 다루는 방법?

우리는 DataFlow를 사용하여 PubSub 항목 집합을 읽고 BigQuery에 데이터를 씁니다. 현재 각 주제에 대해 하나의 DataFlow 작업을 사용하여 관련 BigQuery 테이블에 작성합니다. 이를 위해 하나의 데이터 흐름 작업을 작성할 수 있습니까? https://cloud.google.com/dataflow/pipelines/design-pr

4열

1답변

Google PubSub 오류 [code = 8a75]

오늘이 오류는 산발적으로 발생하기 시작했습니다. Google pubsub 오류 코드는 HTTP 오류 코드에 대해서만 이야기합니다. 누구든지이 오류에 대해 알고 있습니까? 오류 : 서비스가 요청을 이행하지 못했습니다. 다시 시도하십시오. [code = 8a75]

0열

1답변

Google 클라우드 데이터 흐름 : PubSub 스트리밍 모드에서 TextIO.Read가 나는 경우 BigQuery 테이블에 푸른 서버에서 데이터를 전송하는 Google 클라우드 플랫폼을 사용하고 vCPU 한 시간

의 방대한 양을 사용하는 반면 (좋은 작업을 원활하게, 기능적으로 말하기). 파이프 라인은 다음과 같습니다 Dataflow streaming pipeline 파이프 라인의 'FetchMetadata'부분은 내가 GCP 저장 버킷에서 메타 데이터를 .csv 파일 66 라인을 읽을 수있는 간단한 TextIO.Read 구현입니다 : PCollection<Stri

0열

1답변

Google PubSub : 소비자에게 메시지 배포를 맞춤 설정하는 방법

나는 고객 데이터를 pubsub에 보내고 Java 가입자와 함께 사용하는 시나리오가 있습니다. 동일한 구독에 여러 구독자가 구독했습니다. 동일한 고객 ID의 모든 메시지를 동일한 가입자에게 라우팅하는 방법이 있습니까? Google 데이터 흐름에 세션 기반 윈도우가 있음을 알고 있습니다. 그러나 단순한 Java 소비자를 사용하여이를 달성 할 수 있는지 알고