Bereitstellungsmodell für die Weiterleitung der Anwendungsausgabe an ein externes Ziel - Amazon-Kinesis-Data-Analytics für SQL-Anwendungen

Für neue Projekte empfehlen wir, den neuen Managed Service für Apache Flink Studio anstelle von Kinesis-Data-Analytics-for-SQL-Anwendungen zu verwenden. Der Managed Service für Apache Flink Studio kombiniert Benutzerfreundlichkeit mit fortschrittlichen Analysefunktionen, sodass Sie in wenigen Minuten anspruchsvolle Anwendungen zur Stream-Verarbeitung erstellen können.

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.

Bereitstellungsmodell für die Weiterleitung der Anwendungsausgabe an ein externes Ziel

Amazon Kinesis Data Analytics verwendet für die Anwendungsausgabe an die konfigurierten Ziele ein Bereitstellungsmodell nach dem Verfahren „mindestens einmal“. Wenn die Anwendung ausgeführt wird, erstellt Kinesis Data Analytics interne Checkpoints. Diese Checkpoints sind Zeitpunkte, an denen die Ausgabedaten ohne Datenverluste an die Ziele geliefert wurden. Der Service verwendet die Checkpoints nach Bedarf, um sicherzustellen, dass die Ausgabe Ihrer Anwendungen mindestens einmal an die konfigurierten Ziele geliefert wird.

In einer normalen Situation verarbeitet Ihre Anwendung eingehende Daten kontinuierlich. Kinesis Data Analytics schreibt die Ausgabe in die konfigurierten Ziele, z. B. einen Kinesis-Datenstrom oder einen Firehose-Bereitstellungs-Stream. Ihre Anwendung kann jedoch gelegentlich unterbrochen werden, z. B.:

  • Sie möchten möglicherweise die Anwendung anhalten und später erneut starten.

  • Sie löschen die IAM-Rolle, die Kinesis Data Analytics benötigt, um Ihre Anwendungsausgabe zum konfigurierten Ziel zu schreiben. Ohne die IAM-Rolle besitzt Kinesis Data Analytics keine Berechtigungen, um in Ihrem Namen in das externe Ziel zu schreiben.

  • Ein Netzwerkausfall oder der Ausfall eines anderen internen Service führt dazu, dass Ihre Anwendung vorübergehend angehalten wird.

Wenn Ihre Anwendung neu gestartet wird, stellt Kinesis Data Analytics sicher, dass Ausgabedaten weiterhin ab einem Punkt verarbeitet und geschrieben werden, der vor oder an dem Punkt liegt, an dem der Fehler aufgetreten ist. Dadurch wird sichergestellt, dass alle Anwendungsausgaben an die konfigurierten Ziele geliefert werden.

Gehen wir davon aus, dass Sie mehrere Ziele für den selben In-Application-Stream konfiguriert haben. Nachdem die Anwendung nach dem Fehler wiederhergestellt wurde, setzt Kinesis Data Analytics die Ausgabe an die konfigurierten Ziele ab dem letzten Datensatz fort, der an das langsamste Ziel geliefert wurde. Dies kann dazu führen, dass derselbe Ausgabedatensatz mehr als einmal für andere Ziele bereitgestellt wird. In diesem Fall müssen Sie potenzielle Doppelerfassungen im Ziel extern behandeln.