キネシスストリームをクエリするAWSラムダ関数を書くことはできますか？

Question

私はすべてのクリックストリームデータを持つAmazon Kinesisストリームを持っており、KinesisストリームをクエリするためのAPIを書いています。

私の計画は、Kinesisストリームをクエリして戻すAWSラムダ関数を呼び出すAPIゲートウェイを作成することです。

KinesisストリームのクエリにLambdaを使用することはできますか？Kinesis AnalyticsとLambdaを使用する必要がありますか？

Answer 1

LambdaでAWS KinesisをStreamベースのモデルを使用して使用できます。 AWSラムダ自身がキネシスストリームをポーリングし、キネシスからレコード数（あなたが設定したもの）を取得します。ここで

は、より多くの情報です：http://docs.aws.amazon.com/lambda/latest/dg/with-kinesis.html

Answer 2

あなたのアプローチは、AmazonのKinesisストリームを使用するように典型的な方法ではありません。

通常の状況では、データはキネシスストリームに送信され、データは24時間保持されます（ただし、最大7日間設定可能）。あなたのアプリはストリームからデータを抽出し、リアルタイムで何かを更新したり、情報をデータベースに保存したりすることができます。実際には、Amazon Kinesis Firehoseは、Amazon S3、Amazon RedshiftまたはAmazon Elasticsearch Serviceに着信データを自動的に格納できます。

したがって、ストリームは、クエリではなく、が処理されています。です。それらをデータベースではなくの再生可能なキューと考えてください。

また、新しいメッセージがストリームに到着するたびにAmazon Kinesis Streamsをtrigger an AWS Lambda functionにすることができます。これにより、着信情報をほぼリアルタイムで処理することができます。

Answer 3

使用消防ホースのようなものと、あなたは、データを照会するために使用できるElasticsearchに送信します。キネシスストリームは、データストアにロードするなど他の操作を行うまで、データを保持する一時バッファのようなものです。

以下のコメントを参考にして、あなたのやりたいことにキネシス・アナリティクスを使用できます。