今回は、前回作成したAmazon Connect + Kinesis Firehose + Amazon Elasticsearchの仕組みに、Lambdaを組み込んでいきます。なお、Amazon Connectのデータストリーミング機能をまだ有効化されていない方は、前回の記事をご参照ください。

Amazon Connectのデータストリーミング機能を利用して、通話イベントの情報をAmazon Elasticsearchに連携します。Amazon Connectのデータストリーミング機能は、エージェントイベントなどの情報をKinesisを経由してS3やAmazon Elasticsearchに連携できます。

DynamoDBに保存したデータをElasticSearchで可視化する方法をご紹介したいと思います。今回ご紹介する方法は、DynamoDB Streamsをトリガーとし、Lambda経由でElasticSearchにPOSTするという流れになります。