Wählen Sie Ihre Cookie-Einstellungen aus

Wir verwenden essentielle Cookies und ähnliche Tools, die für die Bereitstellung unserer Website und Services erforderlich sind. Wir verwenden Performance-Cookies, um anonyme Statistiken zu sammeln, damit wir verstehen können, wie Kunden unsere Website nutzen, und Verbesserungen vornehmen können. Essentielle Cookies können nicht deaktiviert werden, aber Sie können auf „Anpassen“ oder „Ablehnen“ klicken, um Performance-Cookies abzulehnen.

Wenn Sie damit einverstanden sind, verwenden AWS und zugelassene Drittanbieter auch Cookies, um nützliche Features der Website bereitzustellen, Ihre Präferenzen zu speichern und relevante Inhalte, einschließlich relevanter Werbung, anzuzeigen. Um alle nicht notwendigen Cookies zu akzeptieren oder abzulehnen, klicken Sie auf „Akzeptieren“ oder „Ablehnen“. Um detailliertere Entscheidungen zu treffen, klicken Sie auf „Anpassen“.

Bereitstellung und Abonnement der Event Search and Analytics-Pipeline für Amazon SNS

Fokusmodus
Bereitstellung und Abonnement der Event Search and Analytics-Pipeline für Amazon SNS - Amazon Simple Notification Service

Die vorliegende Übersetzung wurde maschinell erstellt. Im Falle eines Konflikts oder eines Widerspruchs zwischen dieser übersetzten Fassung und der englischen Fassung (einschließlich infolge von Verzögerungen bei der Übersetzung) ist die englische Fassung maßgeblich.

Die vorliegende Übersetzung wurde maschinell erstellt. Im Falle eines Konflikts oder eines Widerspruchs zwischen dieser übersetzten Fassung und der englischen Fassung (einschließlich infolge von Verzögerungen bei der Übersetzung) ist die englische Fassung maßgeblich.

Für die Archivierung und Analyse von Ereignissen empfiehlt Amazon SNS jetzt, die native Integration mit Amazon Data Firehose zu verwenden. Sie können Firehose-Lieferstreams für SNS-Themen abonnieren, sodass Sie Benachrichtigungen an Archivierungs- und Analyseendpunkte wie Amazon Simple Storage Service (Amazon S3) -Buckets, Amazon Redshift Redshift-Tabellen, Amazon OpenSearch Service (OpenSearch Service) und mehr senden können. Die Verwendung von Amazon SNS mit Firehose Delivery Streams ist eine vollständig verwaltete und codelose Lösung, für die Sie keine Funktionen verwenden müssen. AWS Lambda Weitere Informationen finden Sie unter Lieferstreams von Fanout nach Firehose.

In diesem Tutorial wird gezeigt, wie Sie die Ereignissuche- und Analytik-Pipeline bereitstellen und von diesen ein Amazon SNS-Thema abonnieren lassen. Dieser Prozess wandelt die der Pipeline zugeordnete AWS SAM Vorlage automatisch in einen AWS CloudFormation Stack um und stellt den Stack dann in Ihrem Stack bereit. AWS-Konto Dieser Prozess erstellt und konfiguriert außerdem eine Reihe von Ressourcen, die die Ereignissuche und die Analysepipeline umfassen, darunter:

  • Amazon-SQS-Warteschlange

  • Lambda-Funktion

  • Firehose-Bereitstellungsdat

  • Amazon OpenSearch Service-Domäne

  • Amazon S3 Bucket für unzustellbare Nachrichten

Weitere Informationen zur Konfiguration eines Streams mit einem Index als Ziel finden Sie ElasticsearchDestinationConfiguration in der Amazon Data Firehose API-Referenz.

Weitere Informationen zur Transformation von Ereignissen und zur Konfiguration von Ereignispufferung, Ereigniskomprimierung und Ereignisverschlüsselung finden Sie unter Creating an Amazon Data Firehose Delivery Stream im Amazon Data Firehose Developer Guide.

Weitere Informationen zur Filterung von Ereignissen finden Sie unter Filterrichtlinien für Amazon-SNS-Abonnements in diesem Leitfaden.

  1. Melden Sie sich an der AWS Lambda -Konsole an.

  2. Wählen Sie im Navigationsbereich Functions (Funktionen) und dann Create function (Funktion erstellen) aus.

  3. Gehen Sie auf der Seite Create function (Funktion erstellen) wie folgt vor:

    1. Wählen Sie Browse serverless app repository (Repository mit Serverless-Apps durchsuchen), Public applications (Öffentliche Anwendungen), Show apps that create custom roles or resource policies (Apps anzeigen, die benutzerdefinierte IAM-Rollen oder Ressourcenrichtlinien erstellen).

    2. Suchen Sie nach fork-event-search-analytics-pipeline und wählen Sie dann die Anwendung aus.

  4. Gehen Sie auf der Seite fork-event-search-analytics-pipeline wie folgt vor:

    1. Geben Sie im Abschnitt Application settings (Anwendungseinstellungen) einen Application name (Anwendungsname) ein (zum Beispiel my-app-search).

      Anmerkung

      Für jede Bereitstellung muss der Anwendungsname eindeutig sein. Wenn Sie einen Anwendungsnamen wiederverwenden, aktualisiert die Bereitstellung nur den zuvor bereitgestellten AWS CloudFormation Stack (anstatt einen neuen zu erstellen).

    2. (Optional) Geben Sie für den ARN der Lambda-Funktion ein DataTransformationFunctionArn, die für die Transformation eingehender Ereignisse verwendet wird. Wenn Sie keinen Wert eingeben, wird die Datentransformation deaktiviert.

    3. (Optional) Geben Sie eine der folgenden LogLevelEinstellungen für die Ausführung der Lambda-Funktion Ihrer Anwendung ein:

      • DEBUG

      • ERROR

      • INFO (Standard)

      • WARNING

    4. (Optional) Geben Sie für SearchDomainArnden ARN der OpenSearch Service-Domain ein, einen Cluster, der die benötigten Rechen- und Speicherfunktionen konfiguriert. Wenn Sie keinen Wert eingeben, wird eine neue Domäne mit der Standard-Konfiguration erstellt.

    5. Geben Sie für TopicArnden ARN des Amazon SNS SNS-Themas ein, für das diese Instance der Fork-Pipeline abonniert werden soll.

    6. Geben Sie für SearchIndexNameden Namen des OpenSearch Service-Index für die Suche und Analyse von Ereignissen ein.

      Anmerkung

      Die folgenden Kontingente gelten für Indexnamen:

      • Sie dürfen keine Großbuchstaben enthalten.

      • Es dürfen keine der folgenden Zeichen enthalten sein: \ / * ? " < > | ` , #

      • Sie dürfen nicht mit den folgenden Zeichen beginnen: - + _

      • Sie dürfen nicht folgende Zeichen sein: . ..

      • Sie dürfen nicht mehr als 80 Zeichen enthalten.

      • Sie dürfen nicht mehr als 255 Bytes enthalten.

      • Darf keinen Doppelpunkt enthalten (ab OpenSearch Service 7.0)

    7. (Optional) Geben Sie eine der folgenden SearchIndexRotationPeriodEinstellungen für den Rotationszeitraum des OpenSearch Serviceindex ein:

      • NoRotation (Standard)

      • OneDay

      • OneHour

      • OneMonth

      • OneWeek

      Die Indexrotation hängt dem Indexnamen einen Zeitstempel an, was den Ablauf veralteter Daten ermöglicht.

    8. Geben Sie für SearchTypeNameden Namen des OpenSearch Servicetyps für die Organisation der Ereignisse in einem Index ein.

      Anmerkung
      • OpenSearch Namen von Servicetypen können ein beliebiges Zeichen (außer Null-Bytes) enthalten, dürfen aber nicht mit beginnen_.

      • Für OpenSearch Service 6.x kann es nur einen Typ pro Index geben. Wenn Sie einen neuen Typ für einen vorhandenen Index angeben, der bereits einen anderen Typ hat, gibt Firehose einen Laufzeitfehler zurück.

    9. (Optional) Geben Sie für StreamBufferingIntervalInSecondsund StreamBufferingSizeInMBsdie Werte für die Konfiguration der Pufferung eingehender Ereignisse ein. Wenn Sie keine Werte eingeben, 300 Sekunden und 5 MB verwendet.

    10. (Optional) Geben Sie eine der folgenden StreamCompressionFormatEinstellungen für die Komprimierung eingehender Ereignisse ein:

      • GZIP

      • SNAPPY

      • UNCOMPRESSED (Standard)

      • ZIP

    11. (Optional) Geben Sie für das Zeichenkettenpräfix ein StreamPrefix, um Dateien zu benennen, die im Amazon S3 S3-Dead-Letter-Bucket gespeichert sind. Wenn Sie keinen Wert eingeben, wird kein Präfix verwendet.

    12. (Optional) Geben Sie für die Wiederholungsdauer für Fälle ein StreamRetryDurationInSecons, in denen Firehose keine Ereignisse im OpenSearch Serviceindex indizieren kann. Wenn Sie keinen Wert eingeben, wird 300 Sekunden verwendet.

    13. (Optional) Geben Sie für SubscriptionFilterPolicydie Amazon SNS SNS-Abonnementfilterrichtlinie im JSON-Format ein, die zum Filtern eingehender Ereignisse verwendet werden soll. Die Filterrichtlinie entscheidet, welche Ereignisse im OpenSearch Service-Index indexiert werden. Wenn Sie keinen Wert eingeben, wird keine Filterung verwendet wird (alle Ereignisse werden indiziert).

    14. Wählen Sie I acknowledge that this app creates custom IAM roles, resource policies and deploys nested applications (Ich bestätige, dass diese App benutzerdefinierte IAM-Rollen und Ressourcenrichtlinien erstellt und eingebettete Anwendungen bereitstellt) und dann Deploy (Bereitstellen).

Auf der my-app-search Seite Bereitstellungsstatus für zeigt Lambda den Status Ihre Anwendung wird bereitgestellt an.

AWS CloudFormation Beginnt im Abschnitt Ressourcen mit der Erstellung des Stacks und zeigt den CREATE_IN_PROGRESS-Status für jede Ressource an. Wenn der Vorgang abgeschlossen ist, wird der Status CREATE_COMPLETE AWS CloudFormation angezeigt.

Wenn die Bereitstellung abgeschlossen ist, zeigt Lambda den Status Your application has been deployed (Ihre Anwendung wurde bereitgestellt) an.

Nachrichten, die zu Ihrem Amazon SNS SNS-Thema veröffentlicht wurden, werden automatisch im OpenSearch Service-Index indexiert, der von der Event Search and Analytics-Pipeline bereitgestellt wird. Wenn die Pipeline ein Ereignis nicht indizieren kann, speichert sie es in einem Amazon S3 S3-Dead-Letter-Bucket.

DatenschutzNutzungsbedingungen für die WebsiteCookie-Einstellungen
© 2025, Amazon Web Services, Inc. oder Tochtergesellschaften. Alle Rechte vorbehalten.