Mit einem Importthema können Sie Daten aus externen Quellen in Pub/Sub aufnehmen. Anschließend können Sie die Daten an jedes von Pub/Sub unterstützte Ziel streamen.
Pub/Sub unterstützt Amazon Kinesis Data Streams als externe Quelle für die Aufnahme von Daten in ein Importthema.
Themenübersicht importieren
Für ein Importthema ist die Aufnahme des Themas als Property aktiviert. So kann ein Importthema Streamingdaten aufnehmen. Sie können die Aufnahme zu einem Thema mithilfe der Console, der Google Cloud CLI, REST-Aufrufe oder der Clientbibliotheken aktivieren. Im Rahmen der Verwaltung des Importthemas bietet Google Cloud das Monitoring und die Skalierung der Aufnahmepipeline.
Ohne Importthema ist für das Streamen von Daten aus einer Datenquelle in Pub/Sub ein zusätzlicher Dienst erforderlich. Dieser zusätzliche Dienst ruft Daten aus der ursprünglichen Quelle ab und veröffentlicht sie in Pub/Sub. Der zusätzliche Dienst kann eine Streaming-Engine wie Apache Spark oder ein benutzerdefinierter Dienst sein. Außerdem müssen Sie diesen Dienst konfigurieren, bereitstellen, ausführen, skalieren und überwachen.
Im Folgenden finden Sie eine Liste mit wichtigen Informationen zu Importthemen:
Ähnlich wie bei einem Standardthema können Sie weiterhin manuell in einem Importthema veröffentlichen.
Sie können nur eine einzelne Aufnahmequelle an ein Importthema anhängen.
Wir empfehlen, Themen für Streamingdaten zu importieren. Wenn Sie eine Batch-Datenaufnahme in BigQuery anstelle einer Streamingdatenaufnahme in Betracht ziehen, können Sie den BigQuery Data Transfer Service (BQ DTS) ausprobieren. Wenn Sie Daten in Cloud Storage aufnehmen möchten, ist Storage Transfer Service (STS) eine gute Option.
Hinweise
Mehr über den Pub/Sub-Dienst und seine Terminologie erfahren
Konfigurieren Sie die erforderlichen Rollen und Berechtigungen zum Verwalten von Importthemen. Dazu gehört auch das Hinzufügen der Rolle „Pub/Sub-Publisher“ zum Pub/Sub-Dienstkonto und das Hinzufügen der Rolle „Dienstkontonutzer“ zum Dienstkonto.
Richten Sie die Workload Identity-Föderation ein, damit Google Cloud auf den externen Streamingdienst zugreifen kann.
Erforderliche Rollen und Berechtigungen zum Verwalten von Importthemen
Bitten Sie Ihren Administrator, Ihnen die IAM-Rolle „Pub/Sub Editor“ (roles/pubsub.editor
) für Ihr Thema oder Projekt zu gewähren, damit Sie die Berechtigungen erhalten, die Sie zum Erstellen und Verwalten von Importthemen benötigen.
Weitere Informationen zum Zuweisen von Rollen finden Sie unter Zugriff verwalten.
Diese vordefinierte Rolle enthält die Berechtigungen, die zum Erstellen und Verwalten von Importthemen erforderlich sind. Erweitern Sie den Abschnitt Erforderliche Berechtigungen, um die erforderlichen Berechtigungen anzuzeigen:
Erforderliche Berechtigungen
Die folgenden Berechtigungen sind erforderlich, um Importthemen zu erstellen und zu verwalten:
-
Importthema erstellen:
pubsub.topics.create
-
Importthema löschen:
pubsub.topics.delete
-
Importthema abrufen:
pubsub.topics.get
-
Importthema auflisten:
pubsub.topics.list
-
In einem Importthema veröffentlichen:
pubsub.topics.publish
-
Importthema aktualisieren:
pubsub.topics.update
-
Rufen Sie die IAM-Richtlinie für ein Importthema ab:
pubsub.topics.getIamPolicy
-
Konfigurieren Sie die IAM-Richtlinie für ein Importthema:
pubsub.topics.setIamPolicy
Möglicherweise können Sie diese Berechtigungen auch mit benutzerdefinierten Rollen oder anderen vordefinierten Rollen erhalten.
Sie können die Zugriffssteuerung auf Projektebene und auf der Ebene einzelner Ressourcen konfigurieren.
Föderierte Identität für den Zugriff auf Kinesis Data Streams einrichten
Mit der Workload Identity-Föderation können Google Cloud-Dienste auf Arbeitslasten zugreifen, die außerhalb von Google Cloud ausgeführt werden. Mit der Identitätsföderation müssen Sie keine Anmeldedaten verwalten oder an Google Cloud weitergeben, um auf Ihre Ressourcen in anderen Clouds zuzugreifen. Stattdessen können Sie die Identitäten der Arbeitslasten selbst verwenden, um sich bei Google Cloud zu authentifizieren und auf Ressourcen zuzugreifen.
Dienstkonto in Google Cloud erstellen
Dieser Schritt ist optional. Wenn Sie bereits ein Dienstkonto haben, können Sie es in diesem Verfahren verwenden, anstatt ein neues Dienstkonto zu erstellen. Wenn Sie ein vorhandenes Dienstkonto verwenden, fahren Sie im nächsten Schritt mit Eindeutige ID des Dienstkontos aufzeichnen fort.
Bei einem Importthema verwendet Pub/Sub das Dienstkonto als Identität, um auf Ressourcen von AWS zuzugreifen.
Weitere Informationen zum Erstellen eines Dienstkontos, einschließlich der Voraussetzungen, erforderlichen Rollen und Berechtigungen sowie Richtlinien zur Benennung finden Sie unter Dienstkonten erstellen. Nachdem Sie ein Dienstkonto erstellt haben, müssen Sie möglicherweise 60 Sekunden oder länger warten, bevor Sie das Dienstkonto verwenden können. Dieses Verhalten ist darauf zurückzuführen, dass Lesevorgänge letztendlich konsistent sind. Es kann einige Zeit dauern, bis das neue Dienstkonto sichtbar wird.
Eindeutige ID des Dienstkontos notieren
Sie benötigen eine eindeutige Dienstkonto-ID, um eine Rolle in der AWS-Konsole einzurichten.
Rufen Sie in der Google Cloud Console die Seite Dienstkontodetails auf.
Klicken Sie auf das Dienstkonto, das Sie gerade erstellt haben, oder auf das Dienstkonto, das Sie verwenden möchten.
Notieren Sie sich auf der Seite Dienstkontodetails die eindeutige ID.
Sie benötigen die ID im Abschnitt Rolle in AWS mit einer benutzerdefinierten Vertrauensrichtlinie erstellen.
Dem Pub/Sub-Dienstkonto die Rolle „Ersteller von Dienstkonto-Tokens“ hinzufügen
Mit der Rolle „Dienstkontotoken-Ersteller“ (roles/iam.serviceAccountTokenCreator
) können Hauptkonten kurzlebige Anmeldedaten für ein Dienstkonto erstellen. Diese Tokens oder Anmeldedaten werden verwendet, um die Identität des Dienstkontos zu übernehmen.
Weitere Informationen zu Identitätswechsel für Dienstkonten.
Dabei können Sie auch die Rolle „Pub/Sub-Publisher“ (roles/pubsub.publisher
) hinzufügen. Weitere Informationen zu der Rolle und warum Sie sie hinzufügen, finden Sie unter Dem Pub/Sub-Dienstkonto die Rolle „Pub/Sub-Publisher“ hinzufügen.
Öffnen Sie in der Google Cloud Console die Seite IAM.
Aktivieren Sie die Option Von Google bereitgestellte Rollenzuweisungen einschließen.
Suche nach dem Dienstkonto im Format
service-{PROJECT_NUMBER}@gcp-sa-pubsub.iam.gserviceaccount.com
.Klicken Sie für dieses Dienstkonto auf die Schaltfläche Hauptkonto bearbeiten.
Klicken Sie bei Bedarf auf Weitere Rolle hinzufügen.
Wählen Sie die Rolle Ersteller von Dienstkontotokens (
roles/iam.serviceAccountTokenCreator
) aus.Klicken Sie auf Speichern.
Richtlinie in AWS erstellen
Sie benötigen eine Richtlinie in AWS, damit sich Pub/Sub bei AWS authentifizieren kann, damit Pub/Sub Daten aus einem AWS Kinesis-Datenstream aufnehmen kann. Bevor Sie eine AWS-Richtlinie erstellen, erstellen Sie einen Kinesis-Datenstream und einen registrierten Nutzer dafür. Wir empfehlen diese Vorgehensweise, damit Sie die Berechtigungen auf den jeweiligen Stream einschränken können.
Weitere Informationen zum Erstellen eines AWS Kinesis-Datenstreams finden Sie unter Kinesis-Datenstream.
Weitere Informationen zur AWS Kinesis Data Stream API, die zum Registrieren von Nutzern verwendet wird, finden Sie unter RegisterStreamConsumer.
Weitere Methoden und Informationen zum Erstellen einer Richtlinie in AWS finden Sie unter IAM-Richtlinien erstellen.
Führen Sie die folgenden Schritte aus, um eine Richtlinie in AWS zu erstellen:
Melden Sie sich in der AWS-Verwaltungskonsole an und öffnen Sie die IAM-Konsole.
Klicken Sie im Navigationsbereich der Console für IAM auf Zugriffsverwaltung > Richtlinien.
Klicken Sie auf Richtlinie erstellen.
Wählen Sie unter Dienst auswählen die Option Kinesis aus.
Wählen Sie für Aktion zulässig Folgendes aus:
List > ListShards.
Durch diese Aktion wird die Berechtigung zum Auflisten der Shards in einem Stream gewährt und es werden Informationen zu jedem Shard bereitgestellt.
Lesen > SubscribeToShard.
Diese Aktion gewährt die Berechtigung, einen bestimmten Shard mit verbessertem Fan-Out zu überwachen.
Lesen > DescribeStreamConsumer beschreiben.
Mit dieser Aktion wird die Berechtigung zum Abrufen der Beschreibung eines registrierten Streamnutzers gewährt.
Diese Berechtigungen umfassen das Lesen aus dem Stream. Pub/Sub unterstützt nur das Lesen aus einem Kinesis-Stream mit erweitertem Fan-Out mithilfe der Streaming SubscribeToShard API.
Wenn Sie unter Ressourcen die Richtlinie auf einen bestimmten Stream oder Nutzer beschränken möchten (empfohlen), geben Sie den Nutzer-ARN und den Stream-ARN an.
Klicken Sie auf Weitere Berechtigungen hinzufügen.
Geben Sie unter Dienst auswählen die Option STS ein und wählen Sie die Option aus.
Wählen Sie für Aktion zulässig die Option Schreiben > AssumeRoleWithWebIdentity aus.
Diese Aktion gewährt die Berechtigung zum Abrufen eines Satzes temporärer Sicherheitsanmeldedaten, damit Pub/Sub sich über die Identitätsföderation beim Kinesis-Datenstream authentifizieren kann.
Klicken Sie auf Next (Weiter).
Geben Sie einen Namen und eine Beschreibung für die Richtlinie ein.
Klicken Sie auf Richtlinie erstellen.
Rolle in AWS mithilfe einer benutzerdefinierten Vertrauensrichtlinie erstellen
Sie müssen in AWS eine Rolle erstellen, damit sich Pub/Sub bei AWS authentifizieren kann, um Daten aus Kinesis Data Streams aufzunehmen.
Führen Sie die folgenden Schritte aus, um eine Rolle mithilfe einer benutzerdefinierten Vertrauensrichtlinie zu erstellen:
Melden Sie sich in der AWS-Verwaltungskonsole an und öffnen Sie die IAM-Konsole.
Klicken Sie im Navigationsbereich der Console für IAM auf Rollen.
Klicken Sie auf Rolle erstellen.
Wählen Sie unter Vertrauenswürdige Entität auswählen die Option Benutzerdefinierte Vertrauensrichtlinie aus.
Geben oder fügen Sie im Abschnitt Benutzerdefinierte Vertrauensrichtlinie Folgendes ein:
{ "Version": "2012-10-17", "Statement": [ { "Effect": "Allow", "Principal": { "Federated": "accounts.google.com" }, "Action": "sts:AssumeRoleWithWebIdentity", "Condition": { "StringEquals": { "accounts.google.com:sub": "<SERVICE_ACCOUNT_UNIQUE_ID>" } } } ] }
Ersetzen Sie
<SERVICE_ACCOUNT_UNIQUE_ID>
durch die eindeutige ID des Dienstkontos, die Sie unter Eindeutige ID des Dienstkontos notieren notiert haben.Klicken Sie auf Next (Weiter).
Wählen Sie unter Berechtigungen hinzufügen die soeben erstellte benutzerdefinierte Richtlinie aus.
Klicken Sie auf Next (Weiter).
Geben Sie einen Rollennamen und eine Rollenbeschreibung ein.
Klicken Sie auf Rolle erstellen.
Pub/Sub-Publisher-Rolle dem Pub/Sub-Dienstkonto hinzufügen
Sie müssen dem Pub/Sub-Dienstkonto eine Publisher-Rolle zuweisen, damit Pub/Sub aus AWS Kinesis Data Streams im Importthema veröffentlichen kann.
Informationen zum Aktivieren der Veröffentlichung von allen Themen in einem Projekt finden Sie unter Veröffentlichung von allen Themen aktivieren.
Informationen zum Aktivieren der Veröffentlichung von einem bestimmten Thema aus (empfohlen) finden Sie unter Veröffentlichung von einem einzelnen Thema aus aktivieren.
Veröffentlichung für alle Themen aktivieren
Öffnen Sie in der Google Cloud Console die Seite IAM.
Aktivieren Sie die Option Von Google bereitgestellte Rollenzuweisungen einschließen.
Suchen Sie nach dem Dienstkonto im Format
service-{PROJECT_NUMBER}@gcp-sa-pubsub.iam.gserviceaccount.com
.Klicken Sie für dieses Dienstkonto auf die Schaltfläche Hauptkonto bearbeiten.
Klicken Sie bei Bedarf auf Weitere Rolle hinzufügen.
Wählen Sie die Rolle „Pub/Sub-Publisher“ (
roles/pubsub.publisher
) aus.Klicken Sie auf Speichern.
Veröffentlichung aus einem einzelnen Thema aktivieren
Wenn Sie die Berechtigung zum Veröffentlichen nur für ein bestimmtes Importthema erteilen möchten, gehen Sie so vor:
In the Google Cloud console, activate Cloud Shell.
At the bottom of the Google Cloud console, a Cloud Shell session starts and displays a command-line prompt. Cloud Shell is a shell environment with the Google Cloud CLI already installed and with values already set for your current project. It can take a few seconds for the session to initialize.
Führen Sie den Befehl
gcloud pubsub topics add-iam-policy-binding
aus:gcloud pubsub topics add-iam-policy-binding TOPIC_ID\ --member="serviceAccount:service-PROJECT_NUMBER@gcp-sa-pubsub.iam.gserviceaccount.com"\ --role="roles/pubsub.publisher"
Ersetzen Sie Folgendes:
TOPIC_ID ist die Themen-ID des Importthemas.
ist PROJECT_NUMBER die Projektnummer. Informationen zum Anzeigen der Projektnummer finden Sie unter Projekte identifizieren.
Rolle „Dienstkontonutzer“ zum Dienstkonto hinzufügen
Die Rolle Dienstkontonutzer (roles/iam.serviceAccountUser
) enthält die Berechtigung iam.serviceAccounts.actAs
, mit der ein Hauptkonto ein Dienstkonto an die Aufnahmeeinstellungen des Importthemas anhängen und dieses Dienstkonto für die föderierte Identität verwenden kann.
Führen Sie diese Schritte aus:
Öffnen Sie in der Google Cloud Console die Seite IAM.
Klicken Sie für das Hauptkonto, das die Themenaufrufe zum Erstellen oder Aktualisieren ausgibt, auf die Schaltfläche Hauptkonto bearbeiten.
Klicken Sie bei Bedarf auf Weitere Rolle hinzufügen.
Wählen Sie die Rolle „Dienstkontonutzer“ (
roles/iam.serviceAccountUser
) aus.Klicken Sie auf Speichern.
Importthema erstellen
Weitere Informationen zu den Attributen eines Themas finden Sie unter Attribute eines Themas.
Prüfen Sie, ob Sie die folgenden Schritte ausgeführt haben:
Föderierte Identität für den Zugriff auf Kinesis Data Streams einrichten
Dem Pub/Sub-Dienstkonto die Rolle „Pub/Sub-Publisher“ hinzufügen
So erstellen Sie ein Importthema:
Console
-
Rufen Sie in der Google Cloud Console die Seite Themen auf.
-
Klicken Sie auf Thema erstellen.
-
Geben Sie im Feld Themen-ID eine ID für das Importthema ein.
Weitere Informationen zur Benennung von Themen finden Sie in den Benennungsrichtlinien.
-
Wählen Sie Standardabo hinzufügen aus.
-
Wählen Sie Aufnahme aktivieren aus.
-
Wählen Sie als Aufnahmequelle Amazon Kinesis Data Streams aus.
-
Geben Sie die folgenden Informationen ein:
-
Kinesis-Stream-ARN: Der ARN für den Kinesis-Datenstream, den Sie in Pub/Sub aufnehmen möchten. Das ARN-Format sieht so aus:
arn:${Partition}:kinesis:${Region}:${Account}:stream/${StreamName}
. -
Kinesis-Nutzer-ARN: Der ARN der Nutzerressource, die beim AWS Kinesis Data Stream registriert ist. Das ARN-Format sieht so aus:
arn:${Partition}:kinesis:${Region}:${Account}:${StreamType}/${StreamName}/consumer/${ConsumerName}:${ConsumerCreationTimpstamp}
. -
ARN der AWS-Rolle: Der ARN der AWS-Rolle. Das ARN-Format der Rolle sieht so aus:
arn:aws:iam:${Account}:role/${RoleName}
. -
Dienstkonto: Das Dienstkonto, das Sie im Schritt Dienstkonto in Google Cloud erstellen erstellt haben.
-
-
Klicken Sie auf Thema erstellen.
gcloud
-
In the Google Cloud console, activate Cloud Shell.
At the bottom of the Google Cloud console, a Cloud Shell session starts and displays a command-line prompt. Cloud Shell is a shell environment with the Google Cloud CLI already installed and with values already set for your current project. It can take a few seconds for the session to initialize.
-
Führen Sie den Befehl
gcloud pubsub topics create
aus:gcloud pubsub topics create TOPIC_ID
--kinesis-ingestion-stream-arn KINESIS_STREAM_ARN
--kinesis-ingestion-consumer-arn KINESIS_CONSUMER_ARN
--kinesis-ingestion-role-arn KINESIS_ROLE_ARN
--kinesis-ingestion-service-account PUBSUB_SERVICE_ACCOUNTErsetzen Sie Folgendes:
-
TOPIC_ID ist die Themen-ID.
-
KINESIS_STREAM_ARN ist der ARN für die Kinesis Data Streams, die Sie in Pub/Sub aufnehmen möchten. Das ARN-Format sieht so aus:
arn:${Partition}:kinesis:${Region}:${Account}:stream/${StreamName}
. -
KINESIS_CONSUMER_ARN ist der ARN der Nutzerressource, die bei AWS Kinesis Data Streams registriert ist. Das ARN-Format sieht so aus:
arn:${Partition}:kinesis:${Region}:${Account}:${StreamType}/${StreamName}/consumer/${ConsumerName}:${ConsumerCreationTimpstamp}
. -
KINESIS_ROLE_ARN ist der ARN der AWS-Rolle. Das ARN-Format der Rolle sieht so aus:
arn:aws:iam:${Account}:role/${RoleName}
. -
PUBSUB_SERVICE_ACCOUNT ist das Dienstkonto, das Sie unter Dienstkonto in Google Cloud erstellen erstellt haben.
-
Go
Folgen Sie der Einrichtungsanleitung für Go in der Pub/Sub-Kurzanleitung zur Verwendung von Clientbibliotheken, bevor Sie dieses Beispiel ausprobieren. Weitere Informationen finden Sie in der Referenzdokumentation zur Pub/Sub Go API.
Richten Sie Standardanmeldedaten für Anwendungen ein, um sich bei Pub/Sub zu authentifizieren. Weitere Informationen finden Sie unter Authentifizierung für eine lokale Entwicklungsumgebung einrichten.
Java
Folgen Sie der Einrichtungsanleitung für Java in der Pub/Sub-Kurzanleitung zur Verwendung von Clientbibliotheken, bevor Sie dieses Beispiel ausprobieren. Weitere Informationen finden Sie in der Referenzdokumentation zur Pub/Sub Java API.
Richten Sie Standardanmeldedaten für Anwendungen ein, um sich bei Pub/Sub zu authentifizieren. Weitere Informationen finden Sie unter Authentifizierung für eine lokale Entwicklungsumgebung einrichten.
Node.js
Folgen Sie der Einrichtungsanleitung für Node.js in der Pub/Sub-Kurzanleitung zur Verwendung von Clientbibliotheken, bevor Sie dieses Beispiel ausprobieren. Weitere Informationen finden Sie in der Referenzdokumentation zur Pub/Sub Node.js API.
Richten Sie Standardanmeldedaten für Anwendungen ein, um sich bei Pub/Sub zu authentifizieren. Weitere Informationen finden Sie unter Authentifizierung für eine lokale Entwicklungsumgebung einrichten.
Python
Folgen Sie der Einrichtungsanleitung für Python in der Pub/Sub-Kurzanleitung zur Verwendung von Clientbibliotheken, bevor Sie dieses Beispiel ausprobieren. Weitere Informationen finden Sie in der Referenzdokumentation zur Pub/Sub Python API.
Richten Sie Standardanmeldedaten für Anwendungen ein, um sich bei Pub/Sub zu authentifizieren. Weitere Informationen finden Sie unter Authentifizierung für eine lokale Entwicklungsumgebung einrichten.
C
Folgen Sie der Einrichtungsanleitung für C in der Pub/Sub-Kurzanleitung zur Verwendung von Clientbibliotheken, bevor Sie dieses Beispiel ausprobieren. Weitere Informationen finden Sie in der Referenzdokumentation zur Pub/Sub C API.
Richten Sie Standardanmeldedaten für Anwendungen ein, um sich bei Pub/Sub zu authentifizieren. Weitere Informationen finden Sie unter Authentifizierung für eine lokale Entwicklungsumgebung einrichten.
Node.js (TypeScript)
Folgen Sie der Einrichtungsanleitung für Node.js in der Pub/Sub-Kurzanleitung zur Verwendung von Clientbibliotheken, bevor Sie dieses Beispiel ausprobieren. Weitere Informationen finden Sie in der Referenzdokumentation zur Pub/Sub Node.js API.
Richten Sie Standardanmeldedaten für Anwendungen ein, um sich bei Pub/Sub zu authentifizieren. Weitere Informationen finden Sie unter Authentifizierung für eine lokale Entwicklungsumgebung einrichten.
Weitere Informationen zu ARNs finden Sie unter Amazon Resource Names (ARNs) und IAM-Kennungen.
Falls Probleme auftreten, lesen Sie den Hilfeartikel Fehlerbehebung beim Importieren.
Importthema bearbeiten
Sie können die Einstellungen für die Datenquelle der Aufnahme eines Importthemas bearbeiten. Führen Sie diese Schritte aus:
Console
-
Rufen Sie in der Google Cloud Console die Seite Themen auf.
-
Klicken Sie auf das Importthema.
-
Klicken Sie auf der Seite mit den Themendetails auf Bearbeiten.
-
Aktualisieren Sie die Felder, die Sie ändern möchten.
-
Klicken Sie auf Aktualisieren.
gcloud
-
In the Google Cloud console, activate Cloud Shell.
At the bottom of the Google Cloud console, a Cloud Shell session starts and displays a command-line prompt. Cloud Shell is a shell environment with the Google Cloud CLI already installed and with values already set for your current project. It can take a few seconds for the session to initialize.
-
Führen Sie den Befehl
gcloud pubsub topics update
mit allen im folgenden Beispiel genannten Flags aus:gcloud pubsub topics update TOPIC_ID
--kinesis-ingestion-stream-arn KINESIS_STREAM_ARN
--kinesis-ingestion-consumer-arn KINESIS_CONSUMER_ARN
--kinesis-ingestion-role-arn KINESIS_ROLE_ARN
--kinesis-ingestion-service-account PUBSUB_SERVICE_ACCOUNTErsetzen Sie Folgendes:
-
TOPIC_ID ist die Themen-ID. Dieses Feld kann nicht aktualisiert werden.
-
KINESIS_STREAM_ARN ist der ARN für die Kinesis Data Streams, die Sie in Pub/Sub aufnehmen möchten. Das ARN-Format sieht so aus:
arn:${Partition}:kinesis:${Region}:${Account}:stream/${StreamName}
. -
KINESIS_CONSUMER_ARN ist der ARN der Nutzerressource, die bei AWS Kinesis Data Streams registriert ist. Das ARN-Format sieht so aus:
arn:${Partition}:kinesis:${Region}:${Account}:${StreamType}/${StreamName}/consumer/${ConsumerName}:${ConsumerCreationTimpstamp}
. -
KINESIS_ROLE_ARN ist der ARN der AWS-Rolle. Das ARN-Format der Rolle sieht so aus:
arn:aws:iam:${Account}:role/${RoleName}
. -
PUBSUB_SERVICE_ACCOUNT ist das Dienstkonto, das Sie unter Dienstkonto in Google Cloud erstellen erstellt haben.
-
Kontingente und Limits für Importthemen
Der Publisher-Durchsatz für Importthemen ist an das Veröffentlichungskontingent des Themas gebunden. Weitere Informationen finden Sie unter Pub/Sub-Kontingente und -Limits.
Nächste Schritte
Wählen Sie die Art des Abos für Ihr Thema aus.
Informationen zum Veröffentlichen einer Mitteilung in einem Thema
Erstellen oder ändern Sie ein Thema mit der gcloud CLI, REST APIs oder Clientbibliotheken.
Schritte zum Konfigurieren eines Speicherübertragungsjobs, um Daten von AWS S3 zu GCS zu übertragen