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に書き込む権限

td command-lineをなぞってインストール/td.conf

MacでもLinuxでも公式からそのままなぞればおーけー。

td command-line とかでぐぐればいいです。

docs.treasuredata.com

ちなみに、td -e https://api.treasuredata.com account -f でアカウント認証をする必要がありますが、 面倒なので ~/.td/td.conf にこんな感じの設定をねじ込めば、動きます。

[account]
  user = xxxxxxxxxxxx
  apikey = xxxxxxxxxxxx
  endpoint = xxxxxxxxxxx

パーミッションは、.td以下755でいいと思います。