I've been following the steps in the Google tutorial, Using Pub/Sub with Cloud Run tutorial. All ok until allowing Google's service account to create auth tokens (Integrating with Pub/Sub 2.b.) Her...

I have succesfully deployed a 2nd generation cloud function with a storage trigger per the google tutorial. The Cloud Function works when I run a test command in the shell. But if I try for real by...

I have a Google Cloud Pub/Sub subscription that is using a dead-letter topic. I recently had an outage that was preventing a number of messages from being processed & they ended up in the dead-...

I have a BigQuery table I stream updates to from Pub/Sub topic via push subscription writing to it with the topic schema. At some point, I backed up the table with: CREATE TABLE `my-dataset.my-tabl...

I'm currently trying to make some mobile code with Flutter. I'm trying to publish/subscribe data to GCP Cloud Pub/Sub using gcloud library dart. Here is the code for the main.dart: import 'dart:io...

I am working on implementing event driven using GCP Pub/Sub. I have a topic called orders, and that topic will have a subscription named orderPlacedSubscription I have two services that want to lis...

I get an error (in red, in picture below) whilst creating pubsub Bigquery subscription. Error shows up in subscription creation view: First question - why is this error appears in the first place?...

This happens when I try to create a topic TypeError: this.auth.getUniverseDomain is not a function at GrpcClient.createStub (/Users/<...>/node_modules/google-gax/src/grpc.ts:418:48) at pro...

I have integrated GMB API in our platform and working with PubSub to get realtime reviews notification. For which i have already done the following steps: Created topic on google PubSub cloud. ...

I want to install google-cloud-pubsub via pip installation on Mac OS but I get an error: distutils.errors.CompileError: command '/usr/bin/clang' failed with exit code 1. The command I run: pip inst...

We have multiple apps uploaded in a single developer account that are featuring in app subscription. All the apps uploaded on play console have corresponding google cloud project having pub sub set...

I'm setting up a simple Proof of Concept to learn some of the concepts in Google Cloud, specifically PubSub and Dataflow. I have a PubSub topic greeting I've created a simple cloud function that ...

What is the best practise concerning the topic name using google-pubsub. If I have theses events : customer email updated customer address updated customer created customer deleted article creat...

We (as a company) experience large spikes every day. We use Pub/Sub -> Cloud Run combination. The issue we experience is that when high traffic hits, Pub/Sub tries to push messages to Cloud/Run ...

Situation - User completes payments for subscription, the app sends purchase token to the backend with the user id. At the same time, we have also configured webhook, which also send same purchase ...

I'm using Google's Pub/Sub queue to handle messages between services. Some of the subscribers connect to rate-limit APIs. For example, I'm pushing street addresses onto a pub/sub topic. I have a C...

I need to import Pubsub_v1 and bigquery from google.cloud module. I have installed it and pip freeze shows below : gapic-google-cloud-pubsub-v1==0.15.4 google-cloud-bigquery==0.26.0 google-cloud-p...

I am working on cloud functions especially schedule functions. I need to trigger a function periodically each 5 minutes, but in only test step. I need to run it on pubsub emulator without deploying...

so I already have some firebase emulators running on my project (auth, functions and firestore emulators). if I run firebase emulators:start then I will have this 2 messages in my terminal i emula...

I'm using gcloud-node. createTopic api returns error 409, if that topic exist already. Is there a flag that can implicitly create a topic when publishing a message or Is there an API to check if ...

We are moving from an unstable messaging queue service to Google's Pub Sub in NodeJS. It seems to work well but we would like to include error handling. We would like to limit the number of retrie...

I'm trying this example for retrieve data from GCP Pub/Sub at DataFlow. import java.io.FileInputStream; import java.io.FileNotFoundException; import java.io.IOException; import java.time.Instant; i...

I have an API that is containerized and running inside cloud run. How can I get the current project ID where my cloud run is executing? I have tried: I see it in textpayload in logs but I am not s...

I've looked over the documentation for Google's PubSub, and also tried looking in Google Cloud Monitoring, but couldn't find any means of figuring out what's the queue size in my topics. Since I p...

After starting the PubSub emulator using the gcloud CLI and loading the environment variables accordingly, the gcloud CLI remains authenticated with our Google production account. Basically, we did...