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

Insert data from test_l3_longevity into influx database

Browse Source 
Signed-off-by: Matthew Stidham <stidmatt@protonmail.com>
This commit is contained in:
Matthew Stidham
2021-04-08 11:59:43 -07:00
parent a3610f67b0
commit 291216dcb6
2 changed files with 49 additions and 42 deletions
Download Patch File Download Diff File Expand all files Collapse all files

53
py-json/influx.py
View File

@@ -41,32 +41,33 @@ class RecordInflux(LFCliBase):
self.influx_passwd, self.influx_passwd,
self.influx_db) self.influx_db)
def post_to_influx(self, key, value, tags): def post_to_influx(self, key, value):
data = {} data = dict()
data['measurement'] = key data["measurement"] = key
data['tags'] = {} data["tags"] = dict()
for t in tags: data["tags"]["host"] = self.influx_host
data['tags'][t.key] = t.val data["tags"]["region"] = 'us-west'
data['time'] = str(datetime.datetime.utcnow().isoformat()) data["time"] = str(datetime.datetime.utcnow().isoformat())
data['fields'] = {} data["fields"] = dict()
data['fields']['value'] = value data["fields"]["value"] = value
data1 = [data]
print(data1)
# json_body = json.dumps(data) json_body = [
{
# json_body = [ "measurement": key,
# { "tags": {
# "measurement": key, "host": self.influx_host,
# "tags": { "region": "us-west"
# "host": self.host, },
# "region": "us-west" "time": str(datetime.datetime.utcnow().isoformat()),
# }, "fields": {
# "time": str(datetime.datetime.utcnow().isoformat()), "value": value
# "fields": { }
# "value": value }
# } ]
# } print(json_body)
# ] self.client.write_points(data1)
self.client.write_points(data)
# Don't use this unless you are sure you want to. # Don't use this unless you are sure you want to.
# More likely you would want to generate KPI in the # More likely you would want to generate KPI in the
@@ -87,6 +88,6 @@ class RecordInflux(LFCliBase):
# Poke everything into influx db # Poke everything into influx db
for key in response['interface'].keys(): for key in response['interface'].keys():
self.posttoinflux("%s-%s"%(station, key), response['interface'][key]) self.posttoinflux("%s-%s" % (station, key), response['interface'][key])
time.sleep(monitor_interval) time.sleep(monitor_interval)

38
py-scripts/test_l3_longevity.py
View File

@@ -624,23 +624,29 @@ class L3VariableTime(Realm):
key = "" key = ""
val = "" val = ""
# Meta-data for the KPI values. #tags = [MyKvPair] * 5
tags = [MyKvPair] * 5 #tags[0].key = "requested-ul-bps"
tags[0].key = "requested-ul-bps" #tags[0].val = ul
tags[0].val = ul #tags[1].key = "requested-dl-bps"
tags[1].key = "requested-dl-bps" #tags[1].val = dl
tags[1].val = dl #tags[2].key = "ul-pdu-size"
tags[2].key = "ul-pdu-size" #tags[2].val = ul_pdu
tags[2].val = ul_pdu #tags[3].key = "dl-pdu-size"
tags[3].key = "dl-pdu-size" #tags[3].val = dl_pdu
tags[3].val = dl_pdu #tags[4].key = "station-count"
tags[4].key = "station-count" #tags[4].val = sta_count
tags[4].val = sta_count valuemap=dict()
valuemap['requested-ul-bps'] = ul
valuemap['requested-ul-bps'] = dl
valuemap['ul-pdu-size'] = ul_pdu
valuemap['dl-pdu-size'] = dl_pdu
valuemap['station-count'] = sta_count
for key, value in valuemap.items():
self.influxdb.post_to_influx(key, value)
# Provide data points to influxdb. #self.influxdb.post_to_influx("total-download-bps", total_dl_bps, tags)
self.influxdb.post_to_influx("total-download-bps", total_dl_bps, tags) #self.influxdb.post_to_influx("total-upload-bps", total_ul_bps, tags)
self.influxdb.post_to_influx("total-upload-bps", total_ul_bps, tags) #self.influxdb.post_to_influx("total-bi-directional-bps", total_ul_bps + total_dl_bps, tags)
self.influxdb.post_to_influx("total-bi-directional-bps", total_ul_bps + total_dl_bps, tags)
# Stop traffic and admin down stations. # Stop traffic and admin down stations.
def stop(self): def stop(self):