server {
  listen 80;
  server_name www.example.com;

  location / {
    proxy_pass http://localhost:5125;
    proxy_set_header Host $host;
    # proxy_set_headerを追加します。
  }
}

GrowthForecast側

$growthforecast.pl --data-dir /path/to/data/growthforecast --front-proxy=127.0.0.1

のように--front-proxyオプションを追加して起動する。

fluentdの設定

最終的な設定ファイルがこんな感じです。

<source>
    type slackrtm
    token xxxx-xxxx...
    tag slack.rtm
</source>

<filter slack.**>
    @type grep
    regexp1 type ^message$
</filter>

<match slack.**>
    type rewrite_tag_filter
    capitalize_regex_backreference yes
    rewriterule1 channel C012ABCDE filtered.yami
    rewriterule2 channel .+ clear
</match>

<match clear>
    type null
</match>

<match filtered.**>
    type forest
    subtype flowcounter
    <template>
        count_keys type
        unit       minute
        aggregate  all
        tag channel.${tag_parts[1]}
    </template>
</match>

<match channel.**>
    type growthforecast
    gfapi_url /url/for/api
    graph_path dark/slack/${tag}
    name_keys count
    remove_prefix test
</match>

流れ

1. `slackrtm -> filter-grep -> rewrite_tag_filter`

まずSlackのmessageイベント以外をfilterします。
そしてrewrite_tag_filterでchannel名をtagに付与します。
Slack Real Time Messageの場合Channel IDしかメッセージに書いてないので、手でChannel IDとChannel名をマッピングしています。

TODO Slack APIに初め問い合わせて、ID to 名前のMapを作って、来たもの全てを変換するみたいなfilter pluginでも書こうかな

2. `rewrite_tag_filter -> flowcounter`

flowcounter pluginを利用して1分毎のメッセージイベント数をgrowthforecastにforwardします。

3. `flowcounter -> growthforecast`

growthforecast pluginを利用して自前のgrowthforecastにPOSTしています。
graph_pathに${tag}を含めることでどこのチャンネルのグラフなのかがわかります。

${tag}が使えるようになったからforestいらなくねって思ったけどちょっと良くわからない感じにハマった上に体調が最高に悪かったので調査やめました。
そのうち修正します。

結果

Darkの #yami チャンネルのメッセージ数の推移です。
（まあそんな多くないですよね）
昼ぐらいから増え始めて、2時間毎に投稿数が増えて、夕方16時頃に爆発してます。
また、なにかネタが出た時に面白い感じにトゲってくれたらいいなぁって感じですね。

f:id:arata3da4:20151216204401p:plain

Dark とは ?

Dark - Developers at Real Kommunity | Doorkeeper

日頃の行い

個人的な日頃の行いをつらつら書いてます＼＼\\ ٩( 'ω' )و //／／

Slackのメッセージ数の増減をgrowthforecastで見てみる。

概要

GrowthForecast

利用したfluentdのplugin

GrowthForecastのインストール

ちょっとハマったこと

fluentdの設定

流れ

1. `slackrtm -> filter-grep -> rewrite_tag_filter`

2. `rewrite_tag_filter -> flowcounter`

3. `flowcounter -> growthforecast`

結果

Dark とは ?

概要

GrowthForecast

利用したfluentdのplugin

GrowthForecastのインストール

ちょっとハマったこと

fluentdの設定

流れ

1. slackrtm -> filter-grep -> rewrite_tag_filter

2. rewrite_tag_filter -> flowcounter

3. flowcounter -> growthforecast

結果

Dark とは ?

1. `slackrtm -> filter-grep -> rewrite_tag_filter`

2. `rewrite_tag_filter -> flowcounter`

3. `flowcounter -> growthforecast`