google-cloud-pubsub

0열

1답변

기존 구독에 flowControl 옵션을 설정하는 올바른 방법은 무엇입니까?

문서는 topic.getSubscriptions()로 수신 할 수 @google-cloud/[email protected] 구독 기존 구독을 사용하기에 적합한 방법이 무엇인지 말하지 않았지만,받은 구독 구독 flowControl 옵션을 설정 obious 방법이있을 것 같지 않습니다. 또한 topic.createSubscription()은 기존 구독이 발견되

0열

1답변

Python에서 GCP PubSub 주제 정책을 가져 오는 동안 유니 코드 오류

Google Cloud PubSub에서 주제의 정책 세부 정보를 가져 오는 기능이 있습니다. 정책을 가져 와서 사용 권한을 추가하고 업데이트하는 중입니다. python sample docs의 샘플 코드 중 하나를 사용하고 있습니다. 나는 create_iot_topic 함수를 사용하고있다. 다음과 같이 내 코드는 다음과 같습니다 def create_iot_t

0열

1답변

Apache 빔 : 여러 구독에서 읽기

여러 구독을 수신하고 BigQuery에 쓰는 데이터 흐름을 만들고 싶습니다. Google의 documentation에 따라 여러 PCollection 개의 개체를 읽고 조합 할 수 있습니다. 그러나 PubsubIO.Read의 javadoc here을 보면 은 subscription 메서드에서만 허용됩니다. 따라서 여러 구독에서 읽으려면 subscriptio

0열

1답변

PubSub이 종속성 일 때 Apache 빔이 Jetty를 throw합니다.

google-cloud-pubsub (필자의 경우 0.21.1-beta) 종속성 인 경우 Apache Beam이 Jetty ALPN/NPN has not been properly configured 오류를 발생시키는 것을 관찰했습니다. 이 문제를 해결하려면 google-cloud-pubsub을 제거하지 않아도됩니다. 아파치 빔 버전 -

0열

1답변

MQTT를 사용하여 Google 클라우드의 장비 구성 변경 IoT

내 응용 프로그램은 MQTT를 사용하여 이벤트 주제를 등록합니다. 그러나, 장치 설정을 변경하려면 여기 HTTP POST 요청을 사용해야합니다 https://cloud.google.com/iot/docs/reference/rest/v1/projects.locations.registries.devices/modifyCloudToDeviceConfig 제공하는

1열

1답변

로그 내보내기에서 pubsub 페이로드를 LogEntry 개체로 변환하는 방법

게시 하위 주제에 로그 내보내기를 사용하도록 설정했습니다. 데이터 흐름을 사용하여 이러한 로그를 처리하고 관련 열을 BigQuery에 저장합니다. 누군가가 pubsub 메시지 페이로드를 LogEntry 개체로 변환하는 것을 도울 수 있습니까? 다음 코드 시도 : @ProcessElement public void processElement(ProcessCo

0열

1답변

Google pubsub : 교수형 자바 샘플 클라이언트 걸기

google pubsub를 사용하여 가입 된 주제의 메시지를 비동기식으로 가져옵니다. 나는 아래의 샘플 코드를 사용하고 : public void startStreaming() { Subscriber subscriber = null; try { SubscriptionName subscription = SubscriptionN

0열

1답변

비공개 게시자와 일반 가입자를 결합 할 수 있습니까?

Google 클라우드의 계정으로 승인 된 게시자가 게시 된 메시지의 콘텐츠를 제어하면서 메시지를 읽는 주제에 대해 익명의 구독자를 여러 명 가질 수 있도록 Google Cloud Pub/Sub를 구성 할 수 있습니까? 예를 들어 매 초 GOOG 주식 시세 가격을 게시하는 애플리케이션을 제작하고 있다고 가정 해 봅시다. 인터넷에있는 누군가가 내 애플리케이션을

0열

1답변

클라우드 기능 (Firebase 포함)

Google Cloud에서 일부 pub/sub 설정이 있고 Firebase에서 실행중인 일부 Cloud 기능이 있습니다. 사용자 계정을 만들 때 Google Cloud에서 주제에 메시지를 게시 할 수 있도록 Firebase에 트리거를 설정하고 싶습니다. 이것이 가능합니까? 나는 명백한 것을 놓치고 있는가? 계정 생성시 클라우드 기능을 트리거 할 수 있으며

0열

1답변

gcloud pubsub에서 topic 용 protobuf 파일을 추가하는 방법은 무엇입니까?

Google 클라우드의 pubsub에서 새로운 주제를 만들 때 새로운 메시지를 만들어야한다는 것을 알 수 있습니다. 키와 값의 쌍으로 메시지의 전체 구조를 작성해야하는 대신 protobuf 파일을 저장할 수 있습니까? 작성해야 할 protobuf 코드는 this입니다. 만약 protobuf isn gcloud pubsub에 넣어 의미, 어떻게 grpc 클라