2016-07-01 9 views
1

AWSの新機能です。今まで私はaws .net sdkを使ってキネシスストリームにCSVデータを送ることができました。 S3のエミッタを使ってラムダを使ってこのデータをS3に保存する必要があります(これは私が多くのウェブサイトで見つけた最も一般的な方法です)。私はそれのためのラムダ関数を作成します。 Node.jsまたはjava8コードを要求します。 ここから、どのコードをアップロードする必要があるのか​​、S3 Emitterコードの使い方は分かりません。 ストリーミングデータが処理のためにEMRに送信されるため、Kinesis Firehoseを使用できません。 ここで私を助けてください。 別の方法がある場合はお勧めします。AWSラムダを使用してKinesisを読み込んでS3に保存

答えて

0

キネシスストリームからイベントを取得し、それをS3に書き込むコードを書く必要があります(またはKinesis Firehoseでも簡単です)。このコードは現在ラムダでサポートされているプログラミング言語の1つ(JavaScript、Java、Python)になければなりません。ここ はキネシスから読み取るためのチュートリアルです:http://docs.aws.amazon.com/lambda/latest/dg/with-kinesis-example.html

(大規模、圧縮、暗号化されたS3で、より最適化されたバッチを取得するために消防ホースにそれらを書くためにイベントやS3に一括してか、さらに簡単に読むことが比較的容易であり、 ...)。

関連する問題