Google Pub/Sub (Event Stream)
Amplitude Data's Google Pub/Sub integration lets you stream your Amplitude event data straight to Pub/Sub.
Considerations
- Amplitude sends the
user_id,event_name, andcreated_atalong with all user, group, and event properties to Pub/Sub. - The data Amplitude posts in Pub/Sub is the same JSON as documented in the Amplitude Export API.
- This destination supports Identify Forwarding. Anytime you make an Identify call to Amplitude, Amplitude forwards that user information. Refer to the Identify documentation for more information.
- Enter the Google Cloud Service Account as a base64 encoded string.
Set up the integration
Prerequisites
Before you get started, create a topic in Pub/Sub and a Google IAM service account.
Amplitude needs two things from Pub/Sub to set up the integration:
- Pub/Sub topic name: The name of the topic, not the full name in Google Cloud. Refer to the Google Pub/Sub documentation for help with this step.
- Google service account key: Create a dedicated service account for the Amplitude Pub/Sub integration. Refer to the Google documentation for help with this step.
Google Pub/Sub setup
After you create your topic and service role, add the service account as a principal for the topic you created. For more detailed instructions, refer to the Google documentation.
- Open the topic.
- In the Permissions tab, click Add Principal.
- Add the service account's name.
- Select Pub/Sub Publisher as the role.
Next, create a key for the service account. You need this to complete Amplitude setup. Refer to the Google documentation for help with this step.
Amplitude setup
- In Amplitude Data, click Catalog and select the Destinations tab.
- In the Event Streaming section, click Google Pub/Sub.
- Enter a sync name, then click Create Sync.
- Click Edit, then paste your Pub/Sub topic name and Google Cloud service account key.
- Use the Send events filter to select the events to send. Amplitude recommends sending only the most important events.
- When finished, enable the destination and save.
Was this helpful?