Amazon Kinesis 日本にｷﾀ━━━━(ﾟ∀ﾟ)━━━━!! ってことで、とりあえず Twitter の Timeline を kinesis に流すの作ってみた。

Twitter の Stream 扱うには @sora_h 作の akane 使うのが楽なので akane の Strage 先として作ってみた。

なので使い方は簡単で gemfile に

1

gem 'akane-kinesis'

追加して akane.yml にこんな感じで書くと使えます。

1
2
3
4
5
6

storages:
  - kinesis:
      aws_access_key_id: xxx
      aws_secret_access_key: xxxx
      region: ap-northeast-1
      kinesis_stream_name: twitter

とりあえず storages に stdout も指定して実行するとこんな感じのが

こんな感じで json 文字列で kinesis に入ります。

kinesis からの取得側は ここ のサンプルコードで出力してます。

まぁ、遊びで使うにはちょっと高いんだけどね＞＜

コードはコチラ