"""
.. module:: network
:platform: Unix
:synopsis: A source module for network checks
.. moduleauthor:: Colin Alston <colin@imcol.in>
"""
import time
from twisted.internet import defer, reactor
from twisted.web.client import Agent
from twisted.web.http_headers import Headers
from zope.interface import implements
from tensor.interfaces import ITensorSource
from tensor.objects import Source
from tensor.utils import BodyReceiver, fork
[docs]class HTTP(Source):
"""Performs an HTTP request
**Configuration arguments:**
:method: HTTP request method to use
:type method: str.
:match: A text string to match in the document when it is correct
:type match: str.
:useragent: User-Agent header to use
:type useragent: str.
**Metrics:**
:(service name).latency: Time to complete request
"""
implements(ITensorSource)
@defer.inlineCallbacks
def get(self):
agent = Agent(reactor)
method = self.config.get('method', 'GET')
url = self.config.get('url', 'http://%s/' % self.hostname)
match = self.config.get('match', None)
ua = self.config.get('useragent', 'Tensor HTTP checker')
t0 = time.time()
request = yield agent.request(method, url,
Headers({'User-Agent': [ua]}),
)
if request.length:
d = defer.Deferred()
request.deliverBody(BodyReceiver(d))
b = yield d
body = b.read()
else:
body = ""
t_delta = (time.time() - t0) * 1000
if match:
if (match in body):
state = 'ok'
else:
state = 'critical'
else:
state = 'ok'
defer.returnValue(
self.createEvent(state, 'Latency to %s' % url, t_delta,
prefix="latency")
)
[docs]class Ping(Source):
"""Performs an Ping checks against a destination
**Configuration arguments:**
:destination: Host name or IP address to ping
:type method: str.
**Metrics:**
:(service name).latency: Ping latency
:(service name).loss: Packet loss
You can also override the `hostname` argument to make it match
metrics from that host.
"""
implements(ITensorSource)
@defer.inlineCallbacks
def get(self):
host = self.config.get('destination', self.hostname)
out, err, code = yield fork('/bin/ping',
args=('-q', '-n', '-c', '5', '-i', '0.2', host), timeout=30.0)
if code == 0:
# Successful ping
try:
out = out.strip('\n').split('\n')[-2:]
loss = int(out[0].split()[5].strip('%'))
stat = out[1].split()[3].split('/')
pmin, avg, pmax, mdev = [float(i) for i in stat]
event = [
self.createEvent('ok', 'Latency to %s' % host, avg,
prefix="latency"),
self.createEvent('ok', '%s%% loss to %s' % (loss,host), loss,
prefix="loss"),
]
except Exception, e:
print("Could not parse response %s" % repr(out))
event = None
elif code == 1:
# Host unreachable
event = self.createEvent('critical', '100%% loss to %s' % host, 100.0,
prefix="loss")
else:
# Some other kind of error like DNS resolution
event = self.createEvent('critical', 'Unable to reach %s' % host, 100.0,
prefix="loss")
defer.returnValue(event)