投稿日: Sep 15, 2020
Amazon Kinesis Data Analytics for Apache Flink は、Apache Beam Java SDK バージョン 2.23 を使用して構築されたストリーミングアプリケーションのサポートを開始しました。Apache Beam は、複数の実行エンジンで実行できるストリーミングおよびバッチデータ処理アプリケーションを定義するためのオープンソースの統合モデルです。このリリースでは、Java で Apache Beam ストリーミングアプリケーションを構築し、Amazon Kinesis Data Analytics の Apache Flink 1.8、オンプレミスで実行されている Apache Spark、および Apache でサポートされているその他の実行エンジンを使用してそれらのアプリケーションを実行できます。
Amazon Kinesis Data Analytics は、Apache Flink でストリーミングデータをリアルタイムで変換および分析できる最も簡単な方法です。Apache Flink はオープンソースのフレームワークであり、データストリームを処理するためのエンジンです。Amazon Kinesis Data Analytics は、Apache Flink アプリケーションの構築と管理の複雑さを軽減します。Amazon Kinesis Data Analytics for Apache Flink は、組み込みコネクターを使用して、Amazon Managed Streaming for Apache Kafka (Amazon MSK)、Amazon Kinesis Data Streams、Amazon Elasticsearch Service、Amazon DynamoDB ストリーム、Amazon S3、カスタム統合などと統合します。
ここで Amazon Kinesis Data Analytics for Apache Flink の詳細を学び、Streaming Analytics Workshop を通じて独自の Apache Beam パイプラインを構築できます。Amazon Kinesis Data Analytics のリージョンの可用性については、AWS リージョン表を参照してください。
Amazon Kinesis Data Analytics のリージョンの可用性については、AWS リージョン表を参照してください。