nginx_vhost_traffic

#!/bin/sh
#
# Script for monitoring nginx Virtual host output traffic
# 
# Requierements: logtail awk
# one unique access log file with $bytes_sent value for more accuracy
# check http://wiki.nginx.org/NginxHttpLogModule
#
# Configuration Options (all options have defaults)
# [nginx_vhost_traffic]
#
# Virtual host list
# env.vhosts "example.com example.net example.org"
# 
# Log path
# env.logdir = /var/log/nginx
# env.flogfile = access.log 
#
# Position of the $bytes_sent in the access.log file
# env.bparam 11
#
# Aggregate subdomains
# ex: example.com will match www.example.com, webmail.example.com and *example.com 
# BUG: will also match also www.bad-example.com
# env.aggregate true #change to false to disable aggregation 
#
# To report bugs, improvements or get updates
# see http://github.com/joanpc/nginix_vhost_traffic
#
# inspired in postfix_filtered_awk 
# Copyright (c) 2010, Joan Perez i Cauhe

LOGDIR=${logdir:-/var/log/nginx}
ACCESS_LOG=$LOGDIR/${logfile:-access.log}
LOGTAIL=${logtail:-`which logtail`}
STATEFILE=$MUNIN_PLUGSTATE/nginx_vhost_traffic.state
VHOSTS=${vhosts:-`hostname`}
AGGREGATE=${aggregate:true}

BPARAM=${bparam:-11}

case $1 in
   config)
   	DRAW=AREA
	echo 'graph_title Nginx Virtual host traffic'
	echo 'graph_vlabel bits out / ${graph_period}'
	echo 'graph_args --base 1000 -l 0'
	echo 'graph_category webserver'

	i=0
	for vhost in $VHOSTS 
	do 
		i=$(($i + 1))
		echo vhost$i.label $vhost
		echo vhost$i.type ABSOLUTE
		echo vhost$i.cdef vhost$i,8,*
		echo vhost$i.draw $DRAW
		DRAW=STACK
	done
	
	echo rest.label Rest
	echo rest.type ABSOLUTE
	echo rest.cdef rest,8,*
	echo rest.draw STACK
    exit 0;;
esac

export BPARAM
export VHOSTS
export AGGREGATE

# Awk Script
$LOGTAIL ${ACCESS_LOG} -o $STATEFILE | awk '

BEGIN { 
split(ENVIRON["VHOSTS"], hosts)
for (host in hosts) { track[hosts[host]] = host}
}        
{
		cn[$2]+=$ENVIRON["BPARAM"]
}
END { 
		for (host in cn) {		
		if (match(ENVIRON["AGGREGATE"], "true")) {	
			found = 0
			for (vhost in track) {
				if (index(host, vhost)) {
				res[vhost] += cn[host]
				found = 1
				break
				}
			}
			if (! found) rest+=cn[host]
		} else {
			if (host in track) {
				res[host] += cn[host]	
			} else rest+=cn[host]
		}
		}
		print "aggregate: " ENVIRON["AGGREGATE"]
		for (vhost in track) print "vhost" track[vhost] ".value " res[vhost]+0
		print "rest.value " rest + 0
}'