

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.

# AWS Anwendungsbeispiel für Event Fork Pipelines
<a name="example-sns-fork-use-case"></a>

Das folgende Szenario beschreibt eine ereignisgesteuerte, serverlose E-Commerce-Anwendung, die Event Fork-Pipelines verwendet AWS . Sie können diese [E-Commerce-Beispielanwendung](https://serverlessrepo.aws.amazon.com/applications/arn:aws:serverlessrepo:us-east-1:077246666028:applications~fork-example-ecommerce-checkout-api) in der verwenden AWS Serverless Application Repository und sie dann AWS-Konto mithilfe der AWS Lambda Konsole bereitstellen, wo Sie sie testen und ihren Quellcode untersuchen können. GitHub

![Die Architektur einer serverlosen E-Commerce-Anwendung, die integriert AWS-Services werden kann. Es zeigt den Ablauf von E-Commerce-Benutzern, die Bestellungen über ein API Gateway aufgeben, bis hin zu verschiedenen Verarbeitungspipelines, einschließlich Auftragsspeicherung, Suchanalyse und Wiedergabe, und zeigt, wie Ereignisse über Amazon SNS, Lambda, Amazon SQS, DynamoDB und Kibana verwaltet und analysiert werden.](http://docs.aws.amazon.com/de_de/sns/latest/dg/images/sns-fork-example-use-case.png)


Diese E-Commerce-Anwendung nimmt Bestellungen von Käufern über eine RESTful API entgegen, die von API Gateway gehostet und von der AWS Lambda Funktion unterstützt wird`CheckoutApiBackendFunction`. Diese Funktion veröffentlicht alle empfangenen Aufträge zu einem Amazon SNS-Thema mit dem Namen `CheckoutEventsTopic`, das seinerseits die Aufträge an vier unterschiedliche Pipelines weitergibt.

Die erste Pipeline ist die reguläre Checkout-Verarbeitungs-Pipeline, die vom Eigentümer der e-Commerce-Anwendung entworfen und implementiert wurde. Diese Pipeline hat die Amazon SQS SQS-Warteschlange`CheckoutQueue`, die alle eingegangenen Bestellungen zwischenspeichert, eine AWS Lambda Funktion namens, `CheckoutFunction` die die Warteschlange abfragt, um diese Bestellungen zu verarbeiten, und die DynamoDB-Tabelle, in der alle aufgegebenen Bestellungen `CheckoutTable` sicher gespeichert werden.

## Event AWS Fork-Pipelines anwenden
<a name="applying-sns-fork-pipelines"></a>

Die Komponenten der e-Commerce-Anwendung kümmern sich um die zentrale Geschäftslogik. Der Eigentümer der e-Commerce-Anwendung muss sich aber auch um Folgendes kümmern:
+ **Compliance** – sichere, komprimierte Backups, die im Ruhezustand verschlüsselt sind und die Bereinigung sensibler Informationen
+ **Ausfallsicherheit** – Wiederholung aktueller Bestellungen im Falle einer Unterbrechung des Fulfillment-Prozesses
+ **Durchsuchbarkeit** – Ausführen von Analytik und Generierung von Metriken für aufgegebene Aufträge

Anstatt diese Ereignisverarbeitungslogik zu implementieren, kann der Anwendungsbesitzer AWS Event Fork-Pipelines für das `CheckoutEventsTopic` Amazon SNS SNS-Thema abonnieren.
+ [Die Pipeline für die Speicherung und Sicherung von Ereignissen](sns-fork-pipeline-as-subscriber.md#sns-fork-event-storage-and-backup-pipeline) ist für die Transformation von Daten konfiguriert, sodass Kreditkartendaten entfernt, Daten 60 Sekunden gepuffert, Daten mit GZIP komprimiert und mit dem verwalteten Standardschlüssel für Amazon S3 verschlüsselt werden. Dieser Schlüssel wird von AWS Key Management Service ()AWS KMS verwaltet AWS und unterstützt.

  Weitere Informationen finden [Sie unter Wählen Sie Amazon S3 für Ihr Ziel](https://docs.aws.amazon.com/firehose/latest/dev/create-destination.html#create-destination-s3), [Amazon Data Firehose Data Transformation](https://docs.aws.amazon.com/firehose/latest/dev/data-transformation.html) und [Einstellungen konfigurieren](https://docs.aws.amazon.com/firehose/latest/dev/create-configure.html) im *Amazon Data Firehose Developer Guide*.
+ [Die Pipeline für die Suche und Analyse von Ereignissen](sns-fork-pipeline-as-subscriber.md#sns-fork-event-search-and-analytics-pipeline) ist mit einer Index-Wiederholungsdauer von 30 Sekunden konfiguriert, sowie mit einem Bucket für die Speicherung von Aufträgen, die in der Suchdomäne nicht indiziert werden können, und einer Filterrichtlinie zur Einschränkung der indizierten Aufträge.

  Weitere Informationen finden [Sie unter Wählen Sie den OpenSearch Service für Ihr Ziel](https://docs.aws.amazon.com/firehose/latest/dev/create-destination.html#create-destination-elasticsearch) im *Amazon Data Firehose Developer Guide*.
+ [Die Pipeline für das Replay von Events](sns-fork-pipeline-as-subscriber.md#sns-fork-event-replay-pipeline) ist mit dem Amazon-SQS-Warteschlangenteil der normalen Auftragsverarbeitungspipeline konfiguriert, die von Eigentümer der e-Commerce-Anwendung entworfen und implementiert wurde.

  Weitere Informationen finden Sie unter [Name der Warteschlange und URL](https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-general-identifiers.html#queue-name-url) im *Amazon Simple Queue Service Leitfaden für Entwickler*.

Die folgende JSON-Filterrichtlinie ist in der Konfiguration für die Ereignissuche- und Analysepipeline eingestellt. Sie gleicht nur eingehende Aufträge mit einem Gesamtbetrag von mindestens 100 USD ab. Weitere Informationen finden Sie unter [Amazon SNS Nachrichtenfilterung](sns-message-filtering.md).

```
{				
   "amount": [{ "numeric": [ ">=", 100 ] }]
}
```

Mithilfe des AWS Event Fork-Pipelines-Musters kann der Eigentümer der E-Commerce-Anwendung den Entwicklungsaufwand vermeiden, der häufig mit der Programmierung einer undifferenzierten Logik für die Ereignisbehandlung verbunden ist. Stattdessen kann sie AWS Event Fork-Pipelines direkt von ihr aus bereitstellen. AWS Serverless Application Repository AWS-Konto