python tail_mongos.py

tail_mongos.py

import os
import subprocess

import statsd

filename = '/var/log/mongo/mongos.log'
graphite_host = 'statsd.hostedgraphite.com'
graphite_api_key = os.environ['GRAPHITE_API_KEY']

f = subprocess.Popen(
    ['tail', '-F', filename],
    stdout=subprocess.PIPE,
    stderr=subprocess.PIPE)
statsd_client = statsd.StatsClient(
    host=graphite_host,
    port=8125,
    prefix='{}.logs'.format(graphite_api_key)
)

while True:
    try:
        line = f.stdout.readline()
        if 'DBException in process: socket exception [SEND_ERROR]' in line:
            statsd_client.incr(stat='mongos.exception.socket')
    except:
        pass