google-cloud-pubsub

2열

1답변

"시계"요청을 사용하여 이메일을 게시/보조 API에 연결하고 있습니다. 그러나 아래의 코드 (Google에서 제공)를 사용하여 알림을 중지하려고하면 작동하지 않습니다. 나는 파이썬 클라이언트를 사용하고있다. credentials = get_credentials() http = credentials.authorize(httplib2.Http()) serv

5열

1답변

Gmail API 푸시 알림을 필터링 할 수 없습니다.

을 참조하는 Google Pub/Sub를 사용하여 내 애플리케이션에 대한 푸시 알림으로 Gmail inbox event을 가져 오려고했습니다. labelIds을 ['INBOX']으로 신고했지만 Gmail API는 모든 이벤트 (예 : INBOX, SENT, 중요 & 등)에 대한 알림을 보냅니다. 내 파이썬 코드는 아래와 같습니다 credentials = g

0열

1답변

Google PubSub Emulator : 로깅 수준을 구성하는 방법

Google PubSub 에뮬레이터는 어떤 로깅 프레임 워크를 사용하며 어떻게 구성 할 수 있습니까? 매우 장황한 순간에 나는 그것을 침묵하고 싶습니다. 감사합니다.

0열

1답변

Push PubSub Subscription은 한 번 또는 주기적으로 생성해야합니까?

PubSub 항목을 사용하여 데이터를 처리하기위한 대기열을 구현하고 있습니다. 내 계획은 밀어 넣기 구독을 사용하여 게시 된 데이터를 즉시 처리하도록하는 것입니다. 풀 서브를 사용할 때마다 다음 풀주기에 활성 구독이 있음을 보장하기 위해 모든 실행에서 끌어 오기 구독을 다시 만들려고하는 많은 코드 패턴을 보았습니다. 푸시 구독을 사용하여 동일한 작업을 수행

2열

3답변

google.gax.errors.GaxError : GaxError RPC failed by ... StatusCode.UNAVAILABLE

우리는 분산 시스템 중 하나에서 이벤트가 발생하면 기존 주제에 간단하게 게시하려고합니다. 같은 코드는 같습니다 우리를 제외하고는 모든 잡아 다시 추적을 인쇄 할 경우 try: dat = data.encode('utf-8') topic.publish(dat) except: <code to recover> , 우리가 얻을 : g

0열

1답변

Pubsub Hook to Bigquery

나는 데이터 플로우를 플로우로 가지고 있습니다 : 앱 엔진이 pubsub에 게시하여 BigQuery로 푸시합니다. 문서 https://cloud.google.com/python/getting-started/using-pub-sub의 예에서 AppEngine에 호스팅 된 작업자에게 pubsub 푸시를 전송 한 다음 적절한 BigQuery 테이블에 데이터를 처

0열

1답변

Google pubsub에서 Google 클라우드 저장소

클라우드 저장소의 버킷이 pubSub에서 데이터/메시지를 수신 할 수 있습니까? 그렇다면 어떻게? 나는이 somewhere in there docs을 발견 현재 내가 을 pubsub하는 메시지를 게시하고 그리고 난 (그것을 위해 내가 어디서든 찾을 수 없습니다 버킷에 대한 엔드 포인트 URL을 제공해야합니다) 풀 배달 유형을 사용하려면 하지만 작동하지 않았

4열

1답변

gcloud 알파 pubsub 구독 검색 방법을 찾을 수 없음 예외

하나의 Google Cloud Pub/Sub 구독에 대해 전달되지 않은 메시지의 백 로그가 많습니다. 따라 잡기 위해 모든 메시지를 처리 할 필요가 없으며 클라우드 배포를 사용하여 만들어 졌으므로 수동으로 구독을 삭제할 수 없습니다. gcloud seek 명령이 필요한 것 같습니다 (https://cloud.google.com/sdk/gcloud/ref

3열

1답변

Compute Engine에서 Cloud Pub/Sub 주제로 게시 할 때 DEADLINE_EXCEEDED가 발생했습니다.

Google Compute Engine 인스턴스에서 Java 애플리케이션이 실행 중입니다. google-cloud library을 사용하여 클라우드 펍/서브 주제에 메시지를 게시 하려는데 DEADLINE_EXCEEDED 예외가 발생합니다. 코드는 다음과 같습니다 PubSub pubSub = PubSubOptions.getDefaultInstance().to

0열

1답변

com.google.cloud.pubsub API로 외국 프로젝트의 PubSub에 액세스

PubSub에 메시지를 게시하는 AppEngine 앱이 있습니다. 이제 다른 GCP 프로젝트의 메시지를 읽고 싶습니다. com.google.apis/google-api-services-pubsub v1-rev8-1.21.0과 서비스 계정 키를 사용하면 가능합니다. 예제를 https://github.com/GoogleCloudPlatform/cloud-pub