bgruenefeld commented on issue #2124:
URL: https://github.com/apache/iotdb/issues/2124#issuecomment-734413770
hi,
followed your advice and openend for each write operation a separate session
(as i didn´t found the SessionPool).
The result was the same.
Here is the relevant python code excerpt:
import datetime
from datetime import datetime
from iotdb_session.utils.IoTDBConstants import *
from iotdb_session.utils.Tablet import Tablet
from iotdb_session.Session import Session
def open_connection():
try:
connection = Session(host="127.0.0.1", port="6667", user='root',
password='root')
connection.open(False)
except Exception as e:
print( e )
connection.close()
return connection
def save_tablet(device_id, data):
# @param: data is an array with the following structure
# [
# [12345678,1.3,1.0],
# [12345678,1.3,1.0]
# ]
# @param device_id e.g. root.storagegroup.city.device0020
measurements_ = []
values = []
data_types_ = []
timestamps = []
measurements_.append("comsumption")
measurements_.append("status")
data_types_.append(TSDataType.FLOAT)
data_types_.append(TSDataType.FLOAT)
for datapoint in data:
values.append([datapoint[1], datapoint[2]])
timestamps.append(datapoint[0])
tablet_ = Tablet(device_id, measurements_, data_types_, values,
timestamps)
try:
connection = open_connection()
connection.insert_tablet(tablet_)
connection.close()
except Exception as e:
print('an error occured')
print(e)
connection.close()
def create_data(ts_prefix, amount_timeseries):
data = create_timeseries_data(1546300800000, amount)
for index in range(1, amount_timeseries):
device_id = ts_prefix + index
save_tablet(device_id, data)
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
