google-cloud-pubsub

2열

1답변

데이터 흐름에서 GCP PubSub를 읽는 중 문제가 발생합니다. 짧은 시간에 많은 양의 메시지를 게시 할 경우 일부 메시지가 손실된다는 점을 제외하고는 데이터 흐름이 대부분의 보낸 메시지를 받게됩니다. , 다른 메시지가 중복 될 수 있습니다. 그리고 가장 이상한 부분은 손실 된 메시지의 수가 중복되는 메시지의 수와 정확히 동일하다는 것입니다. 예제 중 하

5열

1답변

Pub/Sub에서 BigQuery로 스트리밍

Google PubSub의 일부 데이터를 Python 데이터 흐름을 사용하여 BigQuery로 스트리밍하려고합니다. 내가 options.view_as(StandardOptions).streaming = True 을 설정하여 스트리밍 파이프 라인에 다음 코드 https://github.com/GoogleCloudPlatform/DataflowSDK-exa

5열

2답변

클라우드 pubsub를 기반으로 C# 샘플 프로젝트를 실행할 때 종속성 문제가 발생했습니다.

Google Cloud PubSub를 샘플 C# 프로젝트에 통합하기 위해 노력하고 있습니다.이 프로젝트는 내 회사에서 일하는 유일한 C# 프로젝트 일 수 있으므로 C# 초보자입니다. C#으로 작성된 게임과 통합하기위한 몇 가지 요구 사항 때문입니다. C:/Users/MyUser/RiderProjects/TestConsole/TestConsole/bin/De

0열

1답변

PubSubException : io.grpc.StatusRuntimeException : UNAVAILABLE

사람들이, 내가 Pubsub을 사용하여 다음과 같은 오류 메시지가 점점 오전 : 스레드에서 예외 "주요"com.google.cloud.pubsub.PubSubException : io.grpc. StatusRuntimeException : UNAVAILABLE : HTTP/2 오류 코드 : com.google.api.gax.grpc.ApiException

0열

1답변

pubsub 구독을 삭제하는 가장 좋은 방법은 무엇입니까?

나는 엣지 케이스를 보여 주었고, 일부 메시지는 뽑아 내고 파싱에 실패하는 루프에 갇혀있다. 이 메시지들을 어떻게 없앨 수 있습니까? 나는 gcloud 명령 (gcloud beta pubsub subscriptions pull <SUBSCRIPTION> --auto-ack)으로 --auto-ack를 시도했지만 여전히 나타나고있다. 어떤 아이디어가 있습니까?

0열

1답변

Google Pubsub PubsubMessage ackid 받기

여기 예제를 따르고 있습니다 : https://cloud.google.com/pubsub/docs/quickstart-client-libraries#pubsub-client-libraries-java 그러나 나는 ackid를 얻을 방법을 찾지 못했습니다. 이전 버전 (0.8.0)에서 subscription.pull(1000)을 사용하여 getAckId 메소

0열

1답변

오류 403 : 클라우드에 테스트 메시지를 보내는 중 오류가 발생했습니다. PubSub :이 작업을 수행 할 권한이없는 사용자

푸시 알림 시계를 설정하려고하지만 오류 응답이 표시됩니다. 내가 필요한 허가는 무엇인가? 요청 : // Google API $client = getClient(); // POST request $ch = curl_init('https://www.googleapis.com/gmail/v1/users/me/watch'); curl_setopt_ar

0열

2답변

Google Cloud Pub/Sub 서비스는 "데이터 거주"를 지원합니까?

내 응용 프로그램에서는 Pub/Sub를 통해 보낸 메시지에 포함 된 데이터가 유럽 연합 (EU)의 경계를 벗어나지 않도록해야합니다. 이것은 소위 "데이터 거주"요구 사항과 관련되어 있습니다. Pub/Sub는 서비스의 클라이언트가 메시지가 저장되고 처리되는 특정 위치를 모른 채 메시지를 게시/구독 할 수있는 글로벌 서비스 [1]로 설명됩니다. 내 애플리케이션

9열

1답변

Google Cloud Platform의 Kafka/AWS 키네시스 스트림에 해당합니다.

많은 독자가이 버퍼에서 독립적으로 소비하는 동안 (계속해서 write-once-read-many/WORM) 버퍼에 앱을 계속 추가하고 있습니다. 처음에는 Apache Kafka를 사용하려고 생각했지만 AWS Kinesis Streams + KCL을 조사하기 시작한 as-a-service 옵션을 선호 했으므로이 작업을 수행 할 수있을 것 같습니다. 기본적으로

0열

2답변

Google 클라우드 데이터 흐름 : 동적 파일 이름

다음 작업을 수행 할 것 Google 클라우드 데이터 흐름의 파이프 라인 구축을 위해 노력하고있는 파일에서 읽기 : 이 Pubsub 가입에 대한 이벤트를 수신을 은에서 파일 이름을 추출 이벤트 텍스트 (Google 클라우드 스토리지 버킷에서) 파일을 읽어 의 BigQuery에서 스토어 기록 , 두 번째 단계의 출력을 액세스하고 3에서 사용하는 방법을 아주