参考にしたやつ
AWS Kinesisを使ってみる(Java)(前編) | infoScoop開発者ブログ
データをKinesis StreamへPUT/GETする
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に書き込む権限