首先下载安装包
pip install apache-iotdb
测试例子:
from iotdb.Session import Session
from iotdb.utils.IoTDBConstants import TSDataType
from iotdb.utils.Tablet import Tablet
ip = "192.168.8.161"
port = "6667"
username = "root"
password = "root"
session = Session(ip, port, username, password)
session.open(False)
measurements = ["create_time", "an_shui", "two_temperature","head_coal", "kiln_fire", "kiln_temperature"]
data_types = [
TSDataType.TEXT,
TSDataType.DOUBLE,
TSDataType.DOUBLE,
TSDataType.DOUBLE,
TSDataType.DOUBLE,
TSDataType.DOUBLE,
]
values = [
["2023-08-18 18:06:00", 10, 1101, 15.1, 121.1, 1450],
["2023-08-18 18:07:00", 10, 1101, 15.1, 121.1, 1450],
["2023-08-18 18:07:00", 10, 1101, 15.1, 121.1, 1450],
["2023-08-18 18:07:00", 10, 1101, 15.1, 121.1, 1450],
]
timestamps = [1, 2, 3, 4]
tablet = Tablet(
"root.minite.tags_offline", measurements, data_types, values, timestamps
)
session.insert_tablet(tablet)
with session.execute_statement(
"select ** from root.minite.tags_offline"
) as session_data_set:
while session_data_set.has_next():
print(session_data_set.next())
session.close()
结合pandas 查询例子:
from iotdb.Session import Session
ip = "192.168.8.161"
port = "6667"
username = "root"
password = "root"
session = Session(ip, port, username, password)
session.open(False)
result = session.execute_query_statement("SELECT ** FROM root.minite.tags_offline")
# Transform to Pandas Dataset
df = result.todf()
print(df.head())
session.close()
发表评论