2 from influxdb_client import InfluxDBClient
3 from influxdb_client.client.write_api import SYNCHRONOUS
10 self.client = InfluxDBClient(url = "http://localhost:8086", token="xJVlOom1GRUxDNkldo1v")
14 for col in df.columns:
15 if isinstance(df.iloc[0][col], list):
17 d = df[col].apply(pd.Series)
19 df = df.drop(col, axis=1)
24 df.index = range(len(df))
25 cols = [col for col in df.columns if isinstance(df.iloc[0][col], dict) or isinstance(df.iloc[0][col], list)]
29 d = explode(pd.DataFrame(df[col], columns=[col]))
30 d = d.dropna(axis=1, how='all')
31 df = pd.concat([df, d], axis=1)
32 df = df.drop(col, axis=1).dropna()
33 return jsonToTable(df)
37 df.index = pd.date_range(start=datetime.datetime.now(), freq='10ms', periods=len(df))
38 df['measTimeStampRf'] = df['measTimeStampRf'].apply(lambda x: str(x))
43 df = pd.read_json('cell.json', lines=True)
44 df = df[['cellMeasReport']].dropna()
48 write_api = db.client.write_api(write_options=SYNCHRONOUS)
49 write_api.write(bucket="UEData",record=df, data_frame_measurement_name="liveCell",org="primary")