by shigemk2

当面は技術的なことしか書かない

Kinesis StreamをScalaでごにょごにょ

参考にしたやつ

qiita.com

qiita.com

qiita.com

AWS Kinesisを使ってみる(Java)(前編) | infoScoop開発者ブログ

データをKinesis StreamへPUT/GETする

github.com

5秒毎にデータをPUTしつつ、ログでデータがGET出来ていることを確認するプログラム。

$ aws kinesis create-stream --stream-name kinesis-test-stream --shard-count 1
$ cd my-kinesis-consumer-scala-sample
$ activator run -DaccessKeyId=XXX -DsecretAccessKey=XXX
# ...2つ出てくるmain classの両方共実行する(順不同)

このプログラムに必要なAWSの権限

  • Kinesis Streamに読み書きする権限
  • DynamoDBのテーブルをcreateする権限
  • CloudWatchに書き込む権限