HAProxy の statistics な情報を HTTP 経由の JSON で返す薄っぺらいラッパーを作ってみた（1）

ども。cloudpack の かっぱ (@inokara) です。

前回の続き

前回、無理やり CSV をパースすることなく haproxy-ruby と Sinatra と組み合わせて HTTP 経由で JSON 返すようにすれば CSV パースの呪縛から一瞬で解き放たれたので Sinatra よりもさらに軽い（リソース的にも軽そうに感じる）感じで Web サーバーを上げることが出来ればよりイイのかなって思って Rack 使ってラッパーっぽいのを作ってみました。

HAProxy 側では

stats 有効

以下のように stats を有効にしておきましょう。

stats socket /var/run/haproxy.sock user root group wheel level admin
stats timeout 2m

上記のように設定すれば /var/run/haproxy.socket は root:wheel で作成され管理者レベルでの操作が可能になります。

念のため確認

$ sudo echo "show info" | sudo socat stdio /var/run/haproxy.sock
Name: HAProxy
Version: 1.5.9
Release_date: 2014/11/25
Nbproc: 1
Process_num: 1
Pid: 25459
Uptime: 0d 0h08m21s
Uptime_sec: 501
Memmax_MB: 0
Ulimit-n: 8226
Maxsock: 8226
Maxconn: 4096
Hard_maxconn: 4096
CurrConns: 2
CumConns: 19

(snip)

description:

俺の実装

haproxy-ruby をインストール

sudo gem install haproxy --no-ri --no-rdoc -V

haproxy-ruby は HAProxy の stats を有効にした際の socket ファイル読み込んでパースしてハッシュで値を返す有難いツールです。詳しい使い方については README を見て頂くとして、現状はハッシュでのみ statistics な情報を返す状況です。

Rack アプリケーション

Rack は Rack でもサーバーラックではありません…
Rack アプリケーションは以下のようにシンプルに。

require 'haproxy'
require 'json'

haproxy = HAProxy.read_stats '/var/run/haproxy.sock'
$info =  haproxy.info
$stat =  haproxy.stats

class HaproxyInfo
  def call(env)
    [200, { 'Content-Type' => 'application/json' }, [ $info.to_json ]]
  end
end

class HaproxyStatistics
  def call(env)
    [200, { 'Content-Type' => 'application/json' }, [ $stat.to_json ]]
  end
end

更に config.ru を以下のように書いておきましょう。

require "./haproxy.rb"

use Rack::Reloader, 0
map '/info' do
  run HaproxyInfo.new
end

map '/stats' do
  run HaproxyStatistics.new
end

細かいコードの内容の説明については割愛させて頂きます（本人も見よう見まねな為）

rackup

準備が整ったら rackup でアプリケーションを起動しましょう。

sudo /usr/local/bin/rackup -p 8089 -o 0.0.0.0 &

実行すると以下のように出力されアプリケーションが起動します。

[2015-01-22 15:59:27] INFO  WEBrick 1.3.1
[2015-01-22 15:59:27] INFO  ruby 2.0.0 (2014-11-13) [x86_64-linux]
[2015-01-22 15:59:27] INFO  WEBrick::HTTPServer#start: pid=25530 port=8089

ヲヲ。

念のためポートが Listen しているかも確認しましょう。

$ netstat -an | grep 8089
tcp        0      0 0.0.0.0:8089                0.0.0.0:*                   LISTEN

確認

localhost にて確認

localhost にて確認。

$ curl -s localhost:8089/info | python -m json.tool
127.0.0.1 - - [22/Jan/2015:16:01:48 +0000] "GET /info HTTP/1.1" 200 - 0.0012
{
    "compressbpsin": "0",
    "compressbpsout": "0",
    "compressbpsratelim": "0",
    "connrate": "0",
    "connratelimit": "0",
    "cumconns": "39",
    "cumreq": "39",
    "cumsslconns": "0",
    "currconns": "2",
    "currsslconns": "0",
    "description:": null,
    "hard_maxconn": "4096",
    "idle_pct": "100",
    "maxconn": "4096",
    "maxconnrate": "1",
    "maxpipes": "0",
    "maxsessrate": "1",
    "maxsock": "8226",
    "maxsslconns": "0",
    "maxsslrate": "0",
    "memmax_mb": "0",
    "name": "HAProxy",
    "nbproc": "1",
    "node": "ip-xxx-xx-x-xxx",
    "pid": "25459",
    "pipesfree": "0",
    "pipesused": "0",
    "process_num": "1",
    "release_date": "2014/11/25",
    "run_queue": "1",
    "sessrate": "0",
    "sessratelimit": "0",
    "sslbackendkeyrate": "0",
    "sslbackendmaxkeyrate": "0",
    "sslcachelookups": "0",
    "sslcachemisses": "0",
    "sslfrontendkeyrate": "0",
    "sslfrontendmaxkeyrate": "0",
    "sslfrontendsessionreuse_pct": "0",
    "sslrate": "0",
    "sslratelimit": "0",
    "tasks": "11",
    "ulimit_n": "8226",
    "uptime": "0d 0h17m36s",
    "uptime_sec": "1056",
    "version": "1.5.9"
}

一応、JSON ですね。

せっかくなので HAProxy のバックエンドとして

以下のように HAProxy を設定しておきましょう。

listen statistics 127.0.0.1:19190
  mode http
  server rackapp 127.0.0.1:8089

再起動してアクセスしてみましょう。

$ curl -s localhost:19190/info | python -m json.tool
127.0.0.1 - - [22/Jan/2015:16:09:54 +0000] "GET /info HTTP/1.1" 200 - 0.0012
{
    "compressbpsin": "0",
    "compressbpsout": "0",
    "compressbpsratelim": "0",
    "connrate": "0",
    "connratelimit": "0",
    "cumconns": "39",
    "cumreq": "39",
    "cumsslconns": "0",
    "currconns": "2",
    "currsslconns": "0",
    "description:": null,
    "hard_maxconn": "4096",
    "idle_pct": "100",
    "maxconn": "4096",
    "maxconnrate": "1",
    "maxpipes": "0",
    "maxsessrate": "1",
    "maxsock": "8226",
    "maxsslconns": "0",
    "maxsslrate": "0",
    "memmax_mb": "0",
    "name": "HAProxy",
    "nbproc": "1",
    "node": "ip-xxx-xx-x-xxx",
    "pid": "25459",
    "pipesfree": "0",
    "pipesused": "0",
    "process_num": "1",
    "release_date": "2014/11/25",
    "run_queue": "1",
    "sessrate": "0",
    "sessratelimit": "0",
    "sslbackendkeyrate": "0",
    "sslbackendmaxkeyrate": "0",
    "sslcachelookups": "0",
    "sslcachemisses": "0",
    "sslfrontendkeyrate": "0",
    "sslfrontendmaxkeyrate": "0",
    "sslfrontendsessionreuse_pct": "0",
    "sslrate": "0",
    "sslratelimit": "0",
    "tasks": "11",
    "ulimit_n": "8226",
    "uptime": "0d 0h17m36s",
    "uptime_sec": "1056",
    "version": "1.5.9"
}

一応、レスポンスは返してくれます。一応と書いたのは以下のようなエラーも一緒に出力されてしまいます…。なんでやろ。

$ [2015-01-22 16:09:54] ERROR Errno::ECONNRESET: Connection reset by peer
        /usr/share/ruby/2.0/webrick/httpserver.rb:80:in `eof?'
        /usr/share/ruby/2.0/webrick/httpserver.rb:80:in `run'
        /usr/share/ruby/2.0/webrick/server.rb:295:in `block in start_thread'

調べよかな。

ということで…

やったこと

• haproxy-ruby のいいとこ取りで HAProxy の statistics な情報を JSON で返してくれるアプリケーションっぽいのを作った
• Rack に初めて触ってみた（Sinatra の方が自分のような初心者にはやさしいような気がする）

今後やれそうなこと（やりたいこと）

• パス、又はクエリで出力を絞り込む

感じたこと

• 何かやる前（作る前）に Github とか確認すると思わぬ宝が見つかるかも

作ったと言っても…

作ったと言ってもエラー処理も無く to_json しているだけと言ったらそこまでで大変お恥ずかしい限りですが、JSON で情報が扱えることで他のツールとの連携はしやすくなるのではと考えています。

ということで、おやすみなさい。

元記事はこちらです。
「HAProxy の statistics な情報を HTTP 経由の JSON で返す薄っぺらいラッパーを作ってみた（1）」