diff --git a/py-json/influx.py b/py-json/influx.py index 6aa9bb75..1a85a3a7 100644 --- a/py-json/influx.py +++ b/py-json/influx.py @@ -50,29 +50,14 @@ class RecordInflux(LFCliBase): data["fields"] = dict() data["fields"]["value"] = value 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) # Don't use this unless you are sure you want to. # More likely you would want to generate KPI in the # individual test cases and poke those relatively small bits of # 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, lanforge_host="localhost", devices=None, diff --git a/py-scripts/test_l3_longevity.py b/py-scripts/test_l3_longevity.py index e5c020c5..93120a63 100755 --- a/py-scripts/test_l3_longevity.py +++ b/py-scripts/test_l3_longevity.py @@ -629,6 +629,7 @@ class L3VariableTime(Realm): for key, value in valuemap.items(): tags = dict() tags["region"] = 'us-west' + tags["script"] = 'test_l3_longevity' self.influxdb.post_to_influx(key, value, tags) #self.influxdb.post_to_influx("total-download-bps", total_dl_bps, tags)