99from . import exceptions
1010
1111_LOGGER = logging .getLogger (__name__ )
12- _INSTANCE = 'http://{host}:{port}/api/v{api}/'
13- _DATA_ENDPOINT = 'data?chart={resource}&before=0&after=-1&options=seconds'
14- _ALARMS_ENDPOINT = 'alarms?all&format=json'
15- _ALL_METRIC_ENDPOINT = ('allmetrics?format=json&help=no&types=no&'
16- 'timestamps=yes&names=yes&data=average' )
12+ _INSTANCE = "http://{host}:{port}/api/v{api}/"
13+ _DATA_ENDPOINT = "data?chart={resource}&before=0&after=-1&options=seconds"
14+ _ALARMS_ENDPOINT = "alarms?all&format=json"
15+ _ALL_METRIC_ENDPOINT = (
16+ "allmetrics?format=json&help=no&types=no&" "timestamps=yes&names=yes&data=average"
17+ )
1718
1819API_VERSION = 1
1920
@@ -31,41 +32,37 @@ def __init__(self, host, loop, session, port=19999, data=None):
3132 self .base_url = _INSTANCE .format (host = host , port = port , api = API_VERSION )
3233 if data is None :
3334 self .endpoint = _ALL_METRIC_ENDPOINT
34- if data == ' alarms' :
35+ if data == " alarms" :
3536 self .endpoint = _ALARMS_ENDPOINT
36- if data == ' data' :
37+ if data == " data" :
3738 self .endpoint = _DATA_ENDPOINT
3839
3940 async def get_data (self , resource ):
4041 """Get detail for a resource from the data endpoint."""
41- url = '{}{}' .format (
42- self .base_url , self .endpoint .format (resource = resource ))
42+ url = "{}{}" .format (self .base_url , self .endpoint .format (resource = resource ))
4343
4444 try :
4545 with async_timeout .timeout (5 , loop = self ._loop ):
4646 response = await self ._session .get (url )
4747
48- _LOGGER .info (
49- "Response from Netdata: %s" , response .status )
48+ _LOGGER .info ("Response from Netdata: %s" , response .status )
5049 data = await response .json ()
5150 _LOGGER .debug (data )
52- self .values = {k : v for k , v in zip (
53- data ['labels' ], data ['data' ][0 ])}
51+ self .values = {k : v for k , v in zip (data ["labels" ], data ["data" ][0 ])}
5452
5553 except (asyncio .TimeoutError , aiohttp .ClientError , socket .gaierror ):
5654 _LOGGER .error ("Can not load data from Netdata" )
5755 raise exceptions .NetdataConnectionError ()
5856
5957 async def get_alarms (self ):
6058 """Get alarms for a Netdata instance."""
61- url = ' {}{}' .format (self .base_url , self .endpoint )
59+ url = " {}{}" .format (self .base_url , self .endpoint )
6260
6361 try :
6462 with async_timeout .timeout (5 , loop = self ._loop ):
6563 response = await self ._session .get (url )
6664
67- _LOGGER .debug (
68- "Response from Netdata: %s" , response .status )
65+ _LOGGER .debug ("Response from Netdata: %s" , response .status )
6966 data = await response .text ()
7067 _LOGGER .debug (data )
7168 self .alarms = data
@@ -76,14 +73,13 @@ async def get_alarms(self):
7673
7774 async def get_allmetrics (self ):
7875 """Get all available metrics from a Netdata instance."""
79- url = ' {}{}' .format (self .base_url , self .endpoint )
76+ url = " {}{}" .format (self .base_url , self .endpoint )
8077
8178 try :
8279 with async_timeout .timeout (5 , loop = self ._loop ):
8380 response = await self ._session .get (url )
8481
85- _LOGGER .debug (
86- "Response from Netdata: %s" , response .status )
82+ _LOGGER .debug ("Response from Netdata: %s" , response .status )
8783 data = await response .json ()
8884 _LOGGER .debug (data )
8985 self .metrics = data
0 commit comments