Amazon Managed Service für Apache Flink war zuvor als Amazon Kinesis Data Analytics für Apache Flink bekannt.
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.
Verwenden Sie Konnektoren, um Daten in Managed Service für Apache Flink mit dem DataStream API
Im Amazon Managed Service für Apache Flink DataStream API sind Konnektoren Softwarekomponenten, die Daten in und aus einer Managed Service for Apache Flink-Anwendung übertragen. Konnektoren sind flexible Integrationen, mit denen Sie aus Dateien und Verzeichnissen lesen können. Konnektoren bestehen aus kompletten Modulen für die Interaktion mit Amazon-Services und Systemen von Drittanbietern.
Zu den Konnektoren gehören die folgenden:
Fügen Sie Streaming-Datenquellen zu Managed Service für Apache Flink hinzu: Stellen Ihrer Anwendung Daten aus einem Kinesis Data Stream, einer Datei oder einer anderen Datenquelle zur Verfügung.
Schreiben Sie Daten mithilfe von Senken in Managed Service für Apache Flink: Senden Sie Daten aus Ihrer Anwendung an einen Kinesis-Datenstream, Firehose-Stream oder ein anderes Datenziel.
Verwenden Sie asynchrone I/O in Managed Service für Apache Flink: Ermöglicht asynchronen Zugriff auf eine Datenquelle (z. B. eine Datenbank), um Stream-Ereignisse zu bereichern.
Verfügbare Konnektoren
Das Apache-Flink-Framework enthält Konnektoren für den Zugriff auf Daten aus verschiedenen Quellen. Informationen zu den im Apache Flink-Framework verfügbaren Konnektoren finden Sie unter Konnektoren
Warnung
Wenn Sie Anwendungen haben, die auf Flink 1.6, 1.8, 1.11 oder 1.13 laufen und sie in den Regionen Naher Osten (UAE), Asien-Pazifik (Hyderabad), Israel (Tel Aviv), Europa (Zürich), Naher Osten (), Asien-Pazifik (MelbourneUAE) oder Asien-Pazifik (Jakarta) laufen möchten, müssen Sie möglicherweise Ihr Anwendungsarchiv mit einem aktualisierten Konnektor neu erstellen oder auf Flink 1.18 aktualisieren.
Apache Flink-Konnektoren werden in ihren eigenen Open-Source-Repositorys gespeichert. Wenn Sie auf Version 1.18 oder höher aktualisieren, müssen Sie Ihre Abhängigkeiten aktualisieren. Informationen zum Zugriff auf das Repository für Apache AWS Flink-Konnektoren finden Sie unter. flink-connector-aws
Im Folgenden finden Sie empfohlene Richtlinien:
Konnektor-Upgrades | |||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||
|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|
| Flink-Version | Verwendeter Konnektor | Auflösung | |||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||
| 1.15 | EFO |
Stellen Sie beim Upgrade auf Amazon Managed Service für Apache Flink Version 1.15 sicher, dass Sie den neuesten EFO Connector verwenden. Das muss eine beliebige Version 1.15.3 oder höher sein. Weitere Informationen finden Sie unter: |
|||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||
| 1.15 | Amazon Data Firehose Sink |
Stellen Sie beim Upgrade auf Amazon Managed Service für Apache Flink Version 1.15 sicher, dass Sie die neueste Amazon Data Firehose Sink verwenden. |
|||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||
| 1.15 | Kafka-Anschlüsse |
Stellen Sie beim Upgrade auf Amazon Managed Service für Apache Flink Version 1.15 sicher, dass Sie den neuesten Kafka-Connector verwenden. APIs Apache Flink ist veraltet und. FlinkKafkaConsumerFlinkKafkaProducer |
|||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||
| 1,6 - 1,13 | Firehose |
Ihre Anwendung hängt von einer veralteten Version des Firehose-Konnektors ab, die keine neueren AWS Regionen kennt. Erstellen Sie Ihr Anwendungsarchiv mit Firehose Konnector Version 2.1.0 neu. |
|||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||
| 1.8 | Kinesis |
Ihre Anwendung hängt von einer veralteten Version des Flink Kinesis-Connectors ab, die keine neueren AWS Regionen kennt. Erstellen Sie Ihr Anwendungsarchiv mit Flink Kinesis-Konnector Version 1.6.1 neu. https://github.com/awslabs/amazon-kinesis-connector-flink/tree/1.6.1 |
|||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||
| 1.11 | Kinesis |
Ihre Anwendung hängt von einer veralteten Version des Flink Kinesis-Connectors ab, die keine neueren AWS Regionen kennt. Erstellen Sie Ihr Anwendungsarchiv mit Flink Kinesis-Konnector Version 2.4.1 neu. https://github.com/awslabs/amazon-kinesis-connector-flink/tree/2.4.1 |
|||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||
| 1.6 und 1.13 | Kinesis |
Ihre Anwendung hängt von einer veralteten Version des Flink Kinesis-Connectors ab, die keine neueren AWS Regionen kennt. Leider veröffentlicht Flink keine Patches oder Bugfixes mehr für 1.6/1.13-Konnektoren. Wir empfehlen, auf Flink 1.15 zu aktualisieren, indem Sie Ihr Anwendungsarchiv mit Flink 1.15 neu erstellen. |
|||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||
