mtan93/cachet-url-monitor
1
0
Fork 0
mirror of https://github.com/mtan93/cachet-url-monitor.git synced 2026-05-10 06:16:05 +01:00
Code Issues Packages Projects Releases Wiki Activity

Adding better documentation and more tests, but still missing tests for Scheduler

Browse Source
This commit is contained in:
Mitsuo Takaki
2016-05-01 00:41:33 -07:00
parent f254bddd0f
commit 072aed1024
5 changed files with 80 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
README.md
+56 -1
View File
@@ -4,4 +4,59 @@
cachet-url-monitor cachet-url-monitor
======================== ========================
Python plugin for [cachet](cachethq.io) that monitors an URL, verifying it's response status and latency. Python plugin for [cachet](cachethq.io) that monitors an URL, verifying it's response status and latency. The frequency the URL is tested is configurable, along with the assertion applied to the request response.
## Configuration
```yaml
endpoint:
url: http://www.google.com
method: GET
timeout: 0.010 # seconds
expectation:
- type: HTTP_STATUS
status: 200
- type: LATENCY
threshold: 1
- type: REGEX
regex: ".*<body>.*"
cachet:
api_url: http://status.cachethq.io/api/v1/
token: my_token
component_id: 1
metric_id: 1
frequency: 30
```
- **endpoint**, the configuration about the URL that will be monitored.
- **url**, the URL that is going to be monitored.
- **method**, the HTTP method that will be used by the monitor.
- **timeout**, how long we'll wait to consider the request failed. The unit of it is seconds.
- **expectation**, the list of expectations set for the URL.
- **HTTP_STATUS**, we will verify if the response status code matches what we expect.
- **LATENCY**, we measure how long the request took to get a response and fail if it's above the threshold. The unit is in seconds.
- **REGEX**, we verify if the response body matches the given regex.
- **cachet**, this is the settings for our cachet server.
- **api_url**, the cachet API endpoint.
- **token**, the API token.
- **component_id**, the id of the component we're monitoring. This will be used to update the status of the component.
- **metric_id**, this will be used to store the latency of the API. If this is not set, it will be ignored.
- **frequency**, how often we'll send a request to the given URL. The unit is in seconds.
## Setting up
The application should be installed using **virtualenv**, through the following command:
```
$ git clone git@github.com:mtakaki/cachet-url-monitor.git
$ virtualenv cachet-url-monitor
$ cd cachet-url-monitor
$ source bin/activate
$ pip install -r requirements.txt
```
To start the agent:
```
$ python cachet_url_monitor/scheduler.py config.yml
```
cachet_url_monitor/configuration.py
+2
View File
@@ -20,6 +20,8 @@ class Configuration(object):
self.data = load(file(self.config_file, 'r')) self.data = load(file(self.config_file, 'r'))
self.expectations = [Expectaction.create(expectation) for expectation self.expectations = [Expectaction.create(expectation) for expectation
in self.data['endpoint']['expectation']] in self.data['endpoint']['expectation']]
for expectation in self.expectations:
self.logger.info('Registered expectation: %s' % (expectation,))
def evaluate(self): def evaluate(self):
"""Sends the request to the URL set in the configuration and executes """Sends the request to the URL set in the configuration and executes
cachet_url_monitor/scheduler.py
+4 -1
View File
@@ -30,11 +30,12 @@ class Scheduler(object):
self.logger = logging.getLogger('cachet_url_monitor.scheduler.Scheduler') self.logger = logging.getLogger('cachet_url_monitor.scheduler.Scheduler')
self.configuration = Configuration(config_file) self.configuration = Configuration(config_file)
self.agent = Agent(self.configuration) self.agent = Agent(self.configuration)
self.stop = False
def start(self): def start(self):
self.agent.start() self.agent.start()
self.logger.info('Starting monitor agent...') self.logger.info('Starting monitor agent...')
while True: while not self.stop:
schedule.run_pending() schedule.run_pending()
time.sleep(self.configuration.data['frequency']) time.sleep(self.configuration.data['frequency'])
@@ -42,6 +43,8 @@ class Scheduler(object):
if __name__ == "__main__": if __name__ == "__main__":
FORMAT = "%(levelname)9s [%(asctime)-15s] %(name)s - %(message)s" FORMAT = "%(levelname)9s [%(asctime)-15s] %(name)s - %(message)s"
logging.basicConfig(format=FORMAT, level=logging.INFO) logging.basicConfig(format=FORMAT, level=logging.INFO)
for handler in logging.root.handlers:
handler.addFilter(logging.Filter('cachet_url_monitor'))
if len(sys.argv) <= 1: if len(sys.argv) <= 1:
logging.fatal('Missing configuration file argument') logging.fatal('Missing configuration file argument')
config.yml
+1 -1
View File
@@ -1,7 +1,7 @@
endpoint: endpoint:
url: http://localhost:8080/swagger url: http://localhost:8080/swagger
method: GET method: GET
timeout: 0.010 timeout: 0.01
expectation: expectation:
- type: HTTP_STATUS - type: HTTP_STATUS
status: 200 status: 200
tests/test_scheduler.py
+17 -1
View File
@@ -1,9 +1,11 @@
#!/usr/bin/env python #!/usr/bin/env python
import logging
import mock import mock
import unittest import unittest
import sys import sys
sys.modules['schedule'] = mock.Mock() sys.modules['schedule'] = mock.Mock()
from cachet_url_monitor.scheduler import Agent sys.modules['cachet_url_monitor.configuration.Configuration'] = mock.Mock()
from cachet_url_monitor.scheduler import Agent,Scheduler
class AgentTest(unittest.TestCase): class AgentTest(unittest.TestCase):
@@ -31,3 +33,17 @@ class AgentTest(unittest.TestCase):
every.assert_called_with(5) every.assert_called_with(5)
class SchedulerTest(unittest.TestCase):
def setUp(self):
self.mock_configuration = sys.modules['cachet_url_monitor.configuration.Configuration']
self.scheduler = Scheduler('config.yml')
def test_init(self):
#TODO(mtakaki|2016-05-01): We need more assertions in this test.
assert self.scheduler.stop == False
def test_start(self):
#TODO(mtakaki|2016-05-01): We need a better way of testing this method.
# Leaving it as a placeholder.
self.scheduler.stop = True
self.scheduler.start()