google-cloud-pubsub

0열

1답변

GCS 객체가 서명 된 URL을 통해 업로드 할 때 클라우드 팝/하위로 사용자 정의 데이터를 전송하는 방법

내가 사용하여 Google 클라우드 스토리지 클라우드 팝/하위 알림을 설정할 수 있었다 : gsutil notification create -t [TOPIC_NAME] -m my-key:my-value -f json gs://[BUCKET_NAME] 내 앱 엔진 객체가 GCS로 업로드 될 때마다 서블릿이 올바르게 메시지를받습니다. 내 객체를 GCS에 서명

1열

1답변

한 번에 하나의 메시지 만 꺼내기

임 저는 현재 마스터가 모든 작업을 처음부터 주제로 게시하여 작업 대기열을 초기화하는 간단한 마스터 - 슬레이브 패턴을 실현하고자하는 문제에 직면 해 있습니다. 노예들은 자유로운 일할 수있는 능력을 가질 때마다 그 일자리를 끌어낼 것이며, 한 번에 하나의 직업을 끌어 당겨 실현 될 것입니다. 예제 코드 on github에서 코드가 난 그냥 슬레이브가 작업을

0열

1답변

Google Cloud PubSub 검색어 매개 변수 사용

Cloud PubSub에 메시지를 게시하는 시스템이 있지만 메시지 데이터가 GET 요청의 쿼리 매개 변수로 전달됩니다 (POST 요청 본문 사용과 반대). PubSub은 게시 된 메시지로 HTTP GET 요청을 받아 들일 수 있습니까? Apache Beam Java SDK를 사용하여 이러한 쿼리 매개 변수에 액세스 할 수 있습니까?

1열

1답변

서버에 Google Pub/Sub webhook 호출 후 메시지 콘텐츠를 가져올 수 없습니다.

Google Cloud Pub/Sub에 가입하고 주제를 만들고 내 서버의 URL을 가리키는 webhook이 포함 된 구독을 만들었습니다. 그런 다음 Gmail API를 사용하여 Gmail 계정에서 만든 특정 라벨을보고 내가 작성한 주제와 연결했습니다. 메시지가 내 Gmail 계정의 레이블에 도착하면 webhook에서 내 서버의 URL에 POST 요청을 실행

0열

2답변

Google 클라우드 SDK ImportError를 :</p> <p>나는 다음과 같은 오류를 받고 있어요 'google.cloud 수입 pubsub에서'나는 리눅스에 새로운 오전과 다음을 필요로하는 파이썬 스크립트를 실행하려고 cloud.google

를라는 이름의 모듈 : Traceback (most recent call last): File "file.py", line 2, in <module> from google.cloud import pubsub ImportError: No module named google.cloud 어떻게이 모듈에 액세스 할 수 있습니까? Google

0열

1답변

Android 클라우드 PubSub을 가져올 때 종속성 찾기 버그가 발생했습니다. gradle

빈 Android 프로젝트가 있는데 PubSub Java 클라이언트에 대해 this guide을 팔로우하고 있습니다. 그래서 기본적으로 난 단지 추가 오전 : compile group: 'com.google.cloud', name: 'google-cloud-pubsub', version: '0.11.0-alpha' 내 Gradle을에 (전체 파일이 here

7열

1답변

푸시 구독의 Google Cloud Pub/Sub - INVALID ARGUMENT 오류

& 주제를 생성 한 후 "푸시"배달 유형으로 구독을 만들려고했습니다. https://www.omnea.com/push/google-handler 도메인을 사용하면 (링크가 존재하지 않음) 작동합니다. 그러나 URL https://apidev2.omnea.org/push/google-handler을 사용하면 INVALID_ARGUMENT 오류가 발생합니다.

1열

1답변

Google Pub/Sub 재사용 기존 서브 스크립 션

다음 주/보조 doc에 의존하는 자바 pub/sub 소비자를 만들었습니다. public static void main(String... args) throws Exception { TopicName topic = TopicName.create(pubSubProjectName, pubSubTopic); SubscriptionName s

0열

1답변

GCS에 대한 게시/하위 알림 - 이벤트 필터가 작동하지 않습니다.

GCS에서 파일을 만들 때마다 내 Pub/Sub 구독에 알림을받을 수 있습니다. 그래서 이런 짓을 : gsutil notification create -t projects/[my-project-id]/topics/new-raw-file -f none -m eventType:OBJECT_FINALIZE gs://[the-target-bucket] 내가 g

1열

1답변

스파크 스트리밍 : Google Pubsub의 맞춤 수신기 kryo 등록

나는 Kryo 직렬화와 함께 Spark 2.0.2를 사용하고 있습니다.는 내가 스파크 스트리밍으로 구글 PubSub에서 메시지를 섭취에 대한 사용자 지정 수신기를 구현하려고 해요 :, 내가 일을 직렬화해야한다는이 수신기를 활용하는 스파크 작업을 실행하는 경우에는 class PubSubReceiver(project: String, topic: String,