実行: $ ./activator 'runMain com.hideto0710.main.SlackElasticsearchImport --from 100'
ユニットテスト: $ ./activator test
個別ユニットテスト: $ ./activator 'testOnly com.hideto0710.slack.SlackApiClientSpec'
ドキュメント: $ ./activator doc
Slack API
で取得したデータを Elasticsearch
にインポートする Scala
プログラム。(並行処理に Akka
を利用)
- Slackのチャネル一覧取得
- Slackのコメント取得
- Akkaでの並行処理
- 並行処理数の制限
- コマンドライン引数の値をオプションに反映
- Elasticsearchへのインポート処理
- 処理完了を検知して各Actorを停止
- 各種エラー処理