IoTDB 入门教程实战篇⑤——Python示例（开源）

news2024/11/16 21:21:42

文章目录

一、前文
二、新建Python项目
三、安装依赖
四、示例源码
五、参考

一、前文

IoTDB入门教程——导读

本文详细阐述了如何通过一个Python项目成功连接到IoTDB时序数据库，进而展示了如何向该数据库高效地写入数据以及执行精确的数据查询操作。

此示例旨在为读者提供一个清晰、实用的指导，以便他们在自己的项目中实现与IoTDB的交互。

此示例开源地址：小康师兄/IoTDB示例

二、新建Python项目

新建main.py文件
执行python main.py

在这里插入图片描述

三、安装依赖

pip3 install apache-iotdb

在这里插入图片描述

四、示例源码

此示例开源地址：小康师兄/IoTDB示例

https://gitee.com/weijian.kang/IoTDB-Example/tree/master/Python-Example

import time
from iotdb.Session import Session
from iotdb.utils.IoTDBConstants import TSDataType, TSEncoding, Compressor

# 初始化
session = Session(
    host="xx.xx.xx.xx",
    port="6667",
    user="root",
    password="root",
    fetch_size=1024,
    zone_id="UTC+8",
)

# 打开连接
session.open(False)

# 插入数据
session.insert_record(
    device_id="root.test.test", 
    timestamp=int(time.time()*1000), 
    measurements=["status"], 
    data_types=[TSDataType.DOUBLE],
    values=[0.1])

# 查询数据
result = session.execute_query_statement("select status from root.test.test order by time desc")
while result.has_next():
    print(result.next())


# 关闭连接
session.close()