scottk/wlan-lanforge-scripts
1
0
Fork 0
mirror of https://github.com/Telecominfraproject/wlan-lanforge-scripts.git synced 2025-11-08 14:43:22 +00:00
Code Issues Packages Projects Releases Wiki Activity

give custom datapoint to influx

Browse Source 
Signed-off-by: lanforge <stidmatt@gmail.com>
This commit is contained in:
lanforge
2021-04-07 13:37:22 -07:00
parent fe45a2c657
commit 3470bfd5b5
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
py-json/influx.py
View File

@@ -33,7 +33,7 @@ class RecordInflux(LFCliBase):
self.influx_passwd = _influx_passwd self.influx_passwd = _influx_passwd
self.influx_db = _influx_db self.influx_db = _influx_db
def posttoinflux(self,station,key,response,client): def posttoinflux(self,station,key,value,client):
json_body = [ json_body = [
{ {
"measurement": station + ' ' + key, "measurement": station + ' ' + key,
@@ -43,7 +43,7 @@ class RecordInflux(LFCliBase):
}, },
"time": str(datetime.datetime.utcnow().isoformat()), "time": str(datetime.datetime.utcnow().isoformat()),
"fields": { "fields": {
"value": response['interface'][key] "value": value
} }
} }
] ]
@@ -67,11 +67,11 @@ class RecordInflux(LFCliBase):
response = json.loads(requests.get(url1).text) response = json.loads(requests.get(url1).text)
if target_kpi is None: if target_kpi is None:
for key in response['interface'].keys(): for key in response['interface'].keys():
self.posttoinflux(station, key, response, client) self.posttoinflux(station, key, response['interface'][key], client)
else: else:
targets = target_kpi+['ip','ipv6 address','alias','mac'] targets = target_kpi+['ip','ipv6 address','alias','mac']
response['interface']={your_key: response['interface'][your_key] for your_key in targets} response['interface']={your_key: response['interface'][your_key] for your_key in targets}
for key in response['interface'].keys(): for key in response['interface'].keys():
self.posttoinflux(station, key, response, client) self.posttoinflux(station, key, response['interface'][key], client)
time.sleep(monitor_interval) time.sleep(monitor_interval)