google-cloud-pubsub

1열

1답변

파이썬을 사용하여 비동기 끌어 오기 구독자를 구현했습니다. 이것은 기본 코드 나는 는 A 인쇄해야 def receive_messages(project, subscription_name): subscriber = pubsub_v1.SubscriberClient() subscription_path = subscriber.subscriptio

0열

1답변

Google PubSub은 Python API에 대한 동기화 풀을 지원합니까?

필자가 읽은 문서는 비동기식 풀만을 다룹니다. 파이썬 API를위한 유일한 옵션임을 확인하고 싶습니다.

0열

1답변

은 python SDK appengine/psutil에 대한 pubsub를 가져올 수 없습니다.

pubsub 및 Google App Engine에서 작업하면서 pubsub_v1을 가져 오려고 할 때 psutil과 관련된 문제가 발생합니다. 내가 별도로 실행할 때 Pubsub 좋은 일을하고 있지만 앱 엔진 dev_appserver를 사용하는 경우,이 역 추적을 가지고 : pubsub는 CPU의 활동을 모니터링 할 때이 psutil에 실패처럼 Traceb

0열

1답변

PubSub을 통해 메시지를 보내고 나중에 수신하는 방법

봄 부팅 프로젝트에서 PubSub을 사용하기 시작했으며 PubSub을 사용하여 가능할 지 확실하지 않은 기능을 구현할 계획입니다. 기본적으로 메시지를 주제에 게시해야하며 구독자는 메시지를 즉시 수신 할 필요가 없으며 구독자는 5 일 (다음 날짜)에 메시지를 수신해야합니다. 이것이 가능한지 확실하지 않지만 문서에서 아무것도 찾을 수 없습니다. Queue를 통

0열

1답변

클라우드 기능에서 PubSub 메시지 트리거

Firebase 문서에는 pubSub 주제에 간단하게 가입하는 방법이 나와 있습니다. 합니까 클라우드 기능이나 중포 기지 관리 SDK는 pubSub 이벤트를 게시 할 수있는 방법을 제공하거나 우리는 구글 클라우드 플랫폼 문서에 설명 된 것에 제한됩니다 https://cloud.google.com/pubsub/docs/publisher#pubsub-publi

2열

2답변

AttributeError 문제를 해결하는 방법 : Google Cloud Interactive Shell에서 Python을 실행할 때 '모듈'객체에 '클라이언트'속성이 없습니다.

내 Google에서 PubSub에 실시간으로 데이터를 보내는 트래픽 센서를 시뮬레이트하는 python 스크립트를 실행하려고합니다. 클라우드 쉘. 나는이 오류 google.cloud.pubsub.__file__를 실행 시도 Traceback (most recent call last): File "./send_sensor_data.py", line 8

0열

1답변

Apache Beam Dataflow : 'NoneType'객체에 'parts'속성이 없습니다.

저는 파이프 라인을 작성하여 pubsub에서 스트림을 읽고 apache 빔을 사용하여 Google Cloud Dataflow를 사용하여 bigquery에 씁니다. 이 코드가 있습니다 import apache_beam as beam from apache_beam.transforms.window import FixedWindows topic = 'proj

0열

1답변

일괄 처리를 사용하여 DataFlow의 PubSub에서 읽는 방법

Pubsub 소스의 SDK 1.9.1에는 PubsubIO.Read.maxReadTime 및 PubsubIO.Read.maxNumRecords 개의 메서드가 있습니다. 이러한 메서드를 사용하면 pubsub 메시지에서 바운드 컬렉션을 만들 수 있으므로 일괄 처리 모드에서 Dataflow 파이프 라인을 시작할 수있었습니다. Dataflow SDK 2.1을 사용하

0열

1답변

각 게시/하위 주제에는 자체 연결이 필요합니까?

데이터 추적을 위해 pub/sub를 사용하기 시작합니다. 펍 하위에는 600 개 이상의 주제가 있습니다. 개발자는 각 주제가 GCP 전용 연결을 필요로하므로 애플리케이션은 주제 수와 동일한 추가 파일 설명자가 필요하다고 말했습니다. 이 올바른지? 내가 펍/하위 설명서를 언급을 찾을 수 없습니다. 고맙습니다.

1열

2답변

Google PubSub 메시지 중복

메시지 처리를 위해 python 클라이언트 (Google 클라우드 0.30.0의 일부로 제공됨)를 사용하고 있습니다. 내 메시지가 중복되는 경우가 있습니다 (약 10 %). 나는 같은 메시지를 몇 시간 안에 50 개까지 반복해서 얻을 것이다. 내 가입 설정은 600 초의 확인 시간이지만 메시지는 이전 시간보다 1 분 후에 재전송 될 수 있습니다. 실행 중일