From bc86dede11258e2e5243bb678e10f05d5025c4bd Mon Sep 17 00:00:00 2001 From: Anson Date: Tue, 16 Mar 2021 11:34:00 -0700 Subject: [PATCH] file not relevant to project --- mqttTest.py | 33 --------------------------------- 1 file changed, 33 deletions(-) delete mode 100644 mqttTest.py diff --git a/mqttTest.py b/mqttTest.py deleted file mode 100644 index 57bf49b..0000000 --- a/mqttTest.py +++ /dev/null @@ -1,33 +0,0 @@ -from datetime import datetime -import pandas as pd -from influxdb_client import InfluxDBClient, Point, WritePrecision -from influxdb_client.client.write_api import SYNCHRONOUS -import influxdb_client -from tqdm import tqdm - -# You can generate a Token from the "Tokens Tab" in the UI -token = "RKOjpFKD2e9EUy79rB6pQEYmgmKaGnMy-4hMDnQ_pamEbrrfsMhcP2LjU7ufTRBSyFtRBSKVW5RnET6wq6qOag==" -org = "anson@ansonbiggs.com" -bucket = "anson's Bucket" - -client = InfluxDBClient( - url="https://westeurope-1.azure.cloud2.influxdata.com", token=token -) -write_api = client.write_api(write_options=SYNCHRONOUS) - -df = pd.read_csv("thrustdata.csv") - -ps = [] -for i, row in tqdm(df.iterrows(), total=len(df)): - data = dict(row) - ps.append( - influxdb_client.Point("my_measurement") - .tag("Thrust", "Test") - .field("Thrust", data["Thrust"]) - .field("Pressure", data["Pressure"]) - .field("Time", data["Time"]) - .field("Mass", data["Mass"]) - ) - - -write_api.write(bucket=bucket, org=org, record=ps)