script tag in test_l3_longevity

Signed-off-by: Matthew Stidham <stidmatt@protonmail.com>
This commit is contained in:
Matthew Stidham
2021-04-08 14:18:08 -07:00
parent bb65157ca4
commit 108c014f98
2 changed files with 3 additions and 17 deletions

View File

@@ -50,29 +50,14 @@ class RecordInflux(LFCliBase):
data["fields"] = dict() data["fields"] = dict()
data["fields"]["value"] = value data["fields"]["value"] = value
data1 = [data] data1 = [data]
print(data1)
#json_body = [
# {
# "measurement": key,
# "tags": {
# "host": self.influx_host,
# "region": "us-west"
# },
# "time": str(datetime.datetime.utcnow().isoformat()),
# "fields": {
# "value": value
# }
# }
#]
#print(json_body)
self.client.write_points(data1) self.client.write_points(data1)
# 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
# individual test cases and poke those relatively small bits of # individual test cases and poke those relatively small bits of
# info into influxdb. # info into influxdb.
# This will not return until the 'longevity' timer has expired. # This will not end until the 'longevity' timer has expired.
# This function pushes data directly into the Influx database and defaults to all columns.
def monitor_port_data(self, def monitor_port_data(self,
lanforge_host="localhost", lanforge_host="localhost",
devices=None, devices=None,

View File

@@ -629,6 +629,7 @@ class L3VariableTime(Realm):
for key, value in valuemap.items(): for key, value in valuemap.items():
tags = dict() tags = dict()
tags["region"] = 'us-west' tags["region"] = 'us-west'
tags["script"] = 'test_l3_longevity'
self.influxdb.post_to_influx(key, value, tags) self.influxdb.post_to_influx(key, value, tags)
#self.influxdb.post_to_influx("total-download-bps", total_dl_bps, tags) #self.influxdb.post_to_influx("total-download-bps", total_dl_bps, tags)