187 lines
6.3 KiB
Python
187 lines
6.3 KiB
Python
# Copyright 2015 - Savoir-Faire Linux inc.
|
|
#
|
|
# Licensed under the Apache License, Version 2.0 (the "License"); you may
|
|
# not use this file except in compliance with the License. You may obtain
|
|
# a copy of the License at
|
|
#
|
|
# http://www.apache.org/licenses/LICENSE-2.0
|
|
#
|
|
# Unless required by applicable law or agreed to in writing, software
|
|
# distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
|
|
# WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
|
|
# License for the specific language governing permissions and limitations
|
|
# under the License.
|
|
|
|
import json
|
|
|
|
import requests_mock
|
|
|
|
from surveil.tests.api import functionalTest
|
|
|
|
|
|
class TestHostMetric(functionalTest.FunctionalTest):
|
|
|
|
def setUp(self):
|
|
super(TestHostMetric, self).setUp()
|
|
self.influxdb_response = json.dumps({
|
|
"results": [
|
|
{
|
|
"series": [
|
|
{"name": "metric_load1",
|
|
"tags": {"host_name": "srv-monitoring-01",
|
|
"service_description": "load",
|
|
},
|
|
"columns": [
|
|
"time",
|
|
"critical",
|
|
"min",
|
|
"value",
|
|
"warning"
|
|
],
|
|
"values": [
|
|
["2015-04-19T01:09:24Z",
|
|
"30",
|
|
"0",
|
|
"0.60",
|
|
"15"]
|
|
]},
|
|
{"name": "metric_load1",
|
|
"tags": {"host_name": "test_keystone",
|
|
"service_description": "unload"},
|
|
"columns": [
|
|
"time",
|
|
"critical",
|
|
"min",
|
|
"value",
|
|
"warning"
|
|
],
|
|
"values": [
|
|
["2015-04-19T01:09:23Z",
|
|
"60",
|
|
"0",
|
|
"1.5",
|
|
"20"]
|
|
]},
|
|
{"name": "metric_load1",
|
|
"tags": {"host_name": "ws-arbiter",
|
|
},
|
|
"columns": [
|
|
"time",
|
|
"critical",
|
|
"min",
|
|
"value",
|
|
"warning"
|
|
],
|
|
"values": [
|
|
["2015-04-19T01:09:24Z",
|
|
"20",
|
|
"0",
|
|
"6",
|
|
"10"],
|
|
]}
|
|
]
|
|
}
|
|
]
|
|
})
|
|
|
|
def test_get_metric_hosts(self):
|
|
influxdb_response = json.dumps({
|
|
"results": [
|
|
{
|
|
"series": [
|
|
{
|
|
"name": "metric_load1",
|
|
"tags": {
|
|
"host_name": "srv-monitoring-01",
|
|
"service_description": "load"
|
|
},
|
|
"columns": [
|
|
"time",
|
|
"critical",
|
|
"min",
|
|
"unit",
|
|
"value",
|
|
"warning"
|
|
],
|
|
"values": [
|
|
[
|
|
"2015-07-03T15:18:46Z",
|
|
30,
|
|
0,
|
|
"",
|
|
0.78,
|
|
15
|
|
]
|
|
]
|
|
}
|
|
]
|
|
}
|
|
]
|
|
})
|
|
|
|
with requests_mock.Mocker() as m:
|
|
m.register_uri(requests_mock.GET,
|
|
"http://influxdb:8086/query",
|
|
text=influxdb_response)
|
|
|
|
response = self.get(
|
|
"/v2/status/hosts/srv-monitoring-01/metrics/load1"
|
|
)
|
|
|
|
expected = {
|
|
"metric_name": "load1",
|
|
"min": "0",
|
|
"unit": "",
|
|
"critical": "30",
|
|
"warning": "15",
|
|
"value": "0.78"
|
|
}
|
|
|
|
self.assert_count_equal_backport(
|
|
json.loads(response.body.decode()),
|
|
expected)
|
|
self.assertEqual(
|
|
m.last_request.qs['q'],
|
|
["select * from metric_load1 "
|
|
"where host_name='srv-monitoring-01' "
|
|
"group by service_description "
|
|
"order by time desc limit 1"]
|
|
)
|
|
|
|
def test_metric_names(self):
|
|
self.influxdb_response = json.dumps({
|
|
"results": [
|
|
{
|
|
"series": [
|
|
{
|
|
"name": "measurements",
|
|
"columns": ["name"],
|
|
"values": [
|
|
["metric_rtmin"],
|
|
["ALERT"]
|
|
]
|
|
}
|
|
]
|
|
}
|
|
]
|
|
})
|
|
with requests_mock.Mocker() as m:
|
|
m.register_uri(requests_mock.GET,
|
|
"http://influxdb:8086/query",
|
|
text=self.influxdb_response)
|
|
|
|
response = self.get(
|
|
"/v2/status/hosts/ws-arbiter/metrics"
|
|
)
|
|
|
|
expected = [{"metric_name": "rtmin"}, ]
|
|
|
|
self.assert_count_equal_backport(
|
|
json.loads(response.body.decode()),
|
|
expected)
|
|
self.assertEqual(
|
|
m.last_request.qs['q'],
|
|
["show measurements where host_name='ws-arbiter' "
|
|
"and service_description='__host__'"]
|
|
)
|