redis > incrby aaa 1 で 1 増やすキーが無い時は 0 + 1になる。 redis > incrby aaa -5 もできる、マイナスも増える redis > set neighbor:aaa “{‘aaa’,9}” OK redis > sort neighbor:login by nosort get neighbor:* get * 1) “{‘aaa’,9}” 2) “4” redis > incrby aaa 1 (integer) 5 redis > sort neighbor:login by nosort get neighbor:* get * 1) […]

https://github.com/junichi-otake/fluent-plugin-redis-event-rank にコードをあげました。

rubyあまり書いたこと無いけど、ちょっと書けば動きそうなので http://docs.fluentd.org/articles/plugin-development#writing-buffered-output-plugins http://documents.mazgi.com/fluentd/doc/devel.html#buffered-output-plugins http://fluentd.org/plugin/ を参考に。 event_id rank_key を設定するくらい。 ＊ rubyは、あまり何も見たこと無いのですが はめ込んだだけなので、普通だとは思いますが、枠がしっかりしているので簡単になんでも作れそうです。 ＊ はめ込んで１回で問題なく動いたので、コードを書いたのは5分くらいでしょうか、サンプル色々見て1時間 + ライブラリの設定がわからず1時間と言う感じです。 out_event_rank.rb class Fluent::EventRankOutput < Fluent::BufferedOutput    Fluent::Plugin.register_output(‘event_rank’, self)    config_param :host, :string    config_param :port, :integer, :default => 30110    config_param :event_id, :string    config_param :rank_key, :string    def initialize      super      require ‘redis’    end   […]

fluentd http://fluentd.org/ ・複数のアプリケーションサーバーのログを集約、分散等も可能 ・イベント毎の振り分けが簡単 ・出力先 基本的にやりたいことは全部出来るし、みなさん利用しているようなので使ってみる。 自分で作った変なのをやめて全部こちらに移行する。 > syslogdの話 > http://www.atmarkit.co.jp/flinux/rensai/newlog01/newlog01a.html | APP Server | | Log Server | app → fluentd(td-agent) ⇒A⇒ fluentd → 好きな出力B APP server input socket <> output forward A. ログの転送 app to log server http://docs.fluentd.org/articles/out_forward 分散、失敗した時はファイルに書き出す。 td-agent.conf include conf.d/*.conf include conf.d/*.conf <source>  type unix  path /var/run/td-agent/td-agent.sock </source> <match **>  type […]