Amazon Managed Service für Apache Flink - Amazon Timestream
BeispielanwendungVideo-Tutorial

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.

Amazon Managed Service für Apache Flink

Sie können Apache Flink verwenden, um Ihre Zeitreihendaten von Amazon Managed Service für Apache Flink, Amazon MSK, Apache Kafka und anderen Streaming-Technologien direkt in Amazon Timestream for zu übertragen. LiveAnalytics Wir haben einen Apache Flink-Beispieldaten-Connector für Timestream erstellt. Wir haben auch eine Beispielanwendung für das Senden von Daten an Amazon Kinesis erstellt, sodass die Daten von Kinesis zu Managed Service für Apache Flink und schließlich weiter zu Amazon Timestream fließen können. All diese Artefakte stehen Ihnen in zur Verfügung. GitHub Dieses Video-Tutorial beschreibt die Einrichtung.

Anmerkung

Java 11 ist die empfohlene Version für die Verwendung der Managed Service for Apache Flink-Anwendung. Wenn Sie mehrere Java-Versionen haben, stellen Sie sicher, dass Sie Java 11 in Ihre JAVA_HOME-Umgebungsvariable exportieren.

Beispielanwendung

Gehen Sie zunächst wie folgt vor:

  1. Erstellen Sie in Timestream eine Datenbank mit dem Namen gemäß den kdaflink Anweisungen unter Erstellen einer -Datenbank

  2. Erstellen Sie in Timestream eine Tabelle mit dem Namen gemäß den kinesisdata1 Anweisungen unter Erstellen einer Tabelle

  3. Erstellen Sie einen Amazon Kinesis Data Stream mit dem Namen gemäß den TimestreamTestStream Anweisungen unter Stream erstellen.

  4. Klonen Sie das GitHub Repository für den Apache Flink-Datenconnector für Timestream gemäß den Anweisungen von GitHub

  5. Folgen Sie den Anweisungen in der README-Datei für den Apache Flink-Beispieldatenconnector, um die Beispielanwendung zu kompilieren, auszuführen und zu verwenden

  6. Kompilieren Sie die Anwendung Managed Service for Apache Flink und folgen Sie dabei den Anweisungen zur Kompilierung des Anwendungscodes

  7. Laden Sie die Binärdatei der Anwendung Managed Service for Apache Flink hoch und folgen Sie dabei den Anweisungen zum Hochladen des Apache Flink-Streaming-Codes

    1. Nachdem Sie auf Anwendung erstellen geklickt haben, klicken Sie auf den Link der IAM-Rolle für die Anwendung

    2. Hängen Sie die IAM-Richtlinien für AmazonKinesisReadOnlyAccessund an. AmazonTimestreamFullAccess

      Anmerkung

      Die oben genannten IAM-Richtlinien sind nicht auf bestimmte Ressourcen beschränkt und eignen sich nicht für den Produktionseinsatz. Erwägen Sie für ein Produktionssystem die Verwendung von Richtlinien, die den Zugriff auf bestimmte Ressourcen einschränken.

  8. Klonen Sie das GitHub Repository für die Beispielanwendung, die Daten in Kinesis schreibt. Folgen Sie dabei den Anweisungen von GitHub

  9. Folgen Sie den Anweisungen in der README-Datei, um die Beispielanwendung zum Schreiben von Daten in Kinesis auszuführen.

  10. Führen Sie eine oder mehrere Abfragen in Timestream aus, um sicherzustellen, dass Daten von Kinesis an Managed Service for Apache Flink to Timestream gesendet werden. Folgen Sie dabei den Anweisungen zu Erstellen einer Tabelle

Video-Tutorial

Dieses Video erklärt, wie Timestream mit Managed Service für Apache Flink verwendet wird.