时序数据库-4-[IoTDB]的python3操作

2023-05-16

从采集到存储：时序数据库到底怎么处理时间？
iotdb官方文档手册

1 容器安装iotdb

可以使用docker volume create命令创建 docker 卷。此命令将在/var/lib/docker/volumes目录中创建一个卷。

docker search iotdb
docker pull apache/iotdb
(1)创建数据文件和日志的 docker 挂载目录
docker volume create mydata
docker volume create mylogs

(2)运行docker容器
docker run --name iotdb  -p 6667:6667 -v mydata:/iotdb/data -v mylogs:/iotdb/logs -d apache/iotdb:latest /iotdb/bin/start-server.sh

(3)可以使用docker ps来检查是否运行成功
(4)获取container的ID
docker container ls
(5)进入容器
docker exec -it iotdb /bin/bash
(6)登陆IotDB
/iotdb/sbin/start-cli.sh -h localhost -p 6667 -u root -pw root

2 python操作iotdb

pip3 install iotdb

2.1 session初始化

from iotdb.Session import Session
ip = "192.168.43.212"
port_= "6667"
username_ = "root"
password_ = "root"

session = Session(ip,port_,username_,password_)
session.open(enable_rpc_compression=False)
zone = session.get_time_zone()
session.close()

2.2 存储组管理

设置存储组
session.set_storage_group(group_name)
删除一个或多个存储组
session.delete_storage_group(group_name)
session.delete_storage_groups(group_name_lst)

命令行操作

IoTDB> SET STORAGE GROUP TO root.in

2.3 时间序列管理

创建一个或多个时间序列
session.create_time_series(ts_path, data_type, encoding, compressor,
    props=None, tags=None, attributes=None, alias=None)
      
session.create_multi_time_series(
    ts_path_lst, data_type_lst, encoding_lst, compressor_lst,
    props_lst=None, tags_lst=None, attributes_lst=None, alias_lst=None
)
创建对齐的时间序列
session.create_aligned_time_series(
    device_id, measurements_lst, data_type_lst, encoding_lst, compressor_lst
)
删除一个或多个时间序列
session.delete_time_series(paths_list)
核查指定的时间序列是否存在
session.check_time_series_exists(path)

命令行

IoTDB> CREATE TIMESERIES root.in.wf01.wt01.status WITH DATATYPE=BOOLEAN, ENCODING=PLAIN
IoTDB> CREATE TIMESERIES root.in.wf01.wt01.temperature WITH DATATYPE=FLOAT, ENCODING=RLE
IoTDB> show timeseries

参数说明

create single time series
:param ts_path: String, complete time series path (starts from root)
:param data_type: TSDataType, data type for this time series
:param encoding: TSEncoding, encoding for this time series
:param compressor: Compressor, compressing type for this time series
:param props: Dictionary, properties for time series
:param tags: Dictionary, tag map for time series
:param attributes: Dictionary, attribute map for time series
:param alias: String, measurement alias for time series

3 应用举例

3.1 创建session连接

from iotdb.Session import Session
# creating session connection.
ip = "192.168.124.26"
port_ = "6667"
username_ = "root"
password_ = "root"
session = Session(ip, port_, username_, password_, fetch_size=1024, zone_id="UTC+8")
print(session.get_time_zone())
session.open(False)
session.close()

3.2 创建与删除存储组

from iotdb.Session import Session
# creating session connection.
ip = "192.168.124.26"
port_ = "6667"
username_ = "root"
password_ = "root"
session = Session(ip, port_, username_, password_, fetch_size=1024, zone_id="UTC+8")
print(session.get_time_zone())
session.open(False)

# set and delete storage groups
session.set_storage_group("root.sg_test_01")
session.set_storage_group("root.sg_test_02")
session.set_storage_group("root.sg_test_03")
session.set_storage_group("root.sg_test_04")
session.delete_storage_group("root.sg_test_02")
session.delete_storage_groups(["root.sg_test_03", "root.sg_test_04"])

session.close()

命令行操作

IoTDB> show storage group

3.3 创建时间序列

3.3.1 每次创建一个

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

# creating session connection.
ip = "192.168.124.26"
port_ = "6667"
username_ = "root"
password_ = "root"
session = Session(ip, port_, username_, password_, fetch_size=1024, zone_id="UTC+8")
print(session.get_time_zone())
session.open(False)

# set storage groups
session.set_storage_group("root.sg_test_01")

# setting time series.
session.create_time_series(
    "root.sg_test_01.d_01.s_01", TSDataType.BOOLEAN, TSEncoding.PLAIN, Compressor.SNAPPY)
session.create_time_series(
    "root.sg_test_01.d_01.s_02", TSDataType.INT32, TSEncoding.PLAIN, Compressor.SNAPPY)
session.create_time_series(
    "root.sg_test_01.d_01.s_03", TSDataType.INT64, TSEncoding.PLAIN, Compressor.SNAPPY)

session.create_time_series(
    "root.sg_test_01.d_02.s_01",
    TSDataType.BOOLEAN,
    TSEncoding.PLAIN,
    Compressor.SNAPPY,
    None,
    {"tag1": "v1"},
    {"description": "v1"},
    "temperature",
)
session.close()

3.3.2 每次创建多个

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

# creating session connection.
ip = "192.168.124.26"
port_ = "6667"
username_ = "root"
password_ = "root"
session = Session(ip, port_, username_, password_, fetch_size=1024, zone_id="UTC+8")
print(session.get_time_zone())
session.open(False)

# set storage groups
session.set_storage_group("root.sg_test_01")

# setting multiple time series once.
ts_path_lst_ = [
    "root.sg_test_01.d_01.s_04",
    "root.sg_test_01.d_01.s_05",
    "root.sg_test_01.d_01.s_06",
    "root.sg_test_01.d_01.s_07",
    "root.sg_test_01.d_01.s_08",
    "root.sg_test_01.d_01.s_09",
]
data_type_lst_ = [
    TSDataType.FLOAT,
    TSDataType.DOUBLE,
    TSDataType.TEXT,
    TSDataType.FLOAT,
    TSDataType.DOUBLE,
    TSDataType.TEXT,
]
encoding_lst_ = [TSEncoding.PLAIN for _ in range(len(data_type_lst_))]
compressor_lst_ = [Compressor.SNAPPY for _ in range(len(data_type_lst_))]
session.create_multi_time_series(
    ts_path_lst_, data_type_lst_, encoding_lst_, compressor_lst_
)
session.close()

3.3.3 每次创建多个带标签

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

# creating session connection.
ip = "192.168.124.26"
port_ = "6667"
username_ = "root"
password_ = "root"
session = Session(ip, port_, username_, password_, fetch_size=1024, zone_id="UTC+8")
print(session.get_time_zone())
session.open(False)

# set storage groups
session.set_storage_group("root.sg_test_01")

# setting multiple time series once.
ts_path_lst_ = [
    "root.sg_test_01.d_02.s_04",
    "root.sg_test_01.d_02.s_05",
    "root.sg_test_01.d_02.s_06",
    "root.sg_test_01.d_02.s_07",
    "root.sg_test_01.d_02.s_08",
    "root.sg_test_01.d_02.s_09",
]
data_type_lst_ = [
    TSDataType.FLOAT,
    TSDataType.DOUBLE,
    TSDataType.TEXT,
    TSDataType.FLOAT,
    TSDataType.DOUBLE,
    TSDataType.TEXT,
]
encoding_lst_ = [TSEncoding.PLAIN for _ in range(len(data_type_lst_))]
compressor_lst_ = [Compressor.SNAPPY for _ in range(len(data_type_lst_))]
tags_lst_ = [{"tag2": "v2"} for _ in range(len(data_type_lst_))]
attributes_lst_ = [{"description": "v2"} for _ in range(len(data_type_lst_))]
session.create_multi_time_series(
    ts_path_lst_,
    data_type_lst_,
    encoding_lst_,
    compressor_lst_,
    None,
    tags_lst_,
    attributes_lst_,
    None,
)
session.close()

3.3.4 删除时间序列

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

# creating session connection.
ip = "192.168.124.26"
port_ = "6667"
username_ = "root"
password_ = "root"
session = Session(ip, port_, username_, password_, fetch_size=1024, zone_id="UTC+8")
print(session.get_time_zone())
session.open(False)

# delete time series
session.delete_time_series(
    [
        "root.sg_test_01.d_01.s_07",
        "root.sg_test_01.d_01.s_08",
        "root.sg_test_01.d_01.s_09",
    ]
)

session.close()

3.3.5 检查时间序列

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

# creating session connection.
ip = "192.168.124.26"
port_ = "6667"
username_ = "root"
password_ = "root"
session = Session(ip, port_, username_, password_, fetch_size=1024, zone_id="UTC+8")
print(session.get_time_zone())
session.open(False)
# checking time series
print(
    "s_07 expecting False, checking result: ",
    session.check_time_series_exists("root.sg_test_01.d_01.s_07"),
)
print(
    "s_03 expecting True, checking result: ",
    session.check_time_series_exists("root.sg_test_01.d_01.s_03"),
)
print(
    "d_02.s_01 expecting True, checking result: ",
    session.check_time_series_exists("root.sg_test_01.d_02.s_01"),
)
print(
    "d_02.s_06 expecting True, checking result: ",
    session.check_time_series_exists("root.sg_test_01.d_02.s_06"),
)
session.close()

3.4 插入数据

3.4.1 插入一条记录

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

# creating session connection.
ip = "192.168.124.26"
port_ = "6667"
username_ = "root"
password_ = "root"
session = Session(ip, port_, username_, password_, fetch_size=1024, zone_id="UTC+8")
print(session.get_time_zone())
session.open(False)

# insert one record into the database.
measurements_ = ["s_01", "s_02", "s_03", "s_04", "s_05", "s_06"]
values_ = [False, 10, 11, 1.1, 10011.1, "test_record"]
data_types_ = [
    TSDataType.BOOLEAN,
    TSDataType.INT32,
    TSDataType.INT64,
    TSDataType.FLOAT,
    TSDataType.DOUBLE,
    TSDataType.TEXT,
]
session.insert_record("root.sg_test_01.d_01", 1, measurements_, data_types_, values_)
session.close()

命令行

IoTDB> select * from root.sg_test_01.d_01

3.4.2 插入多条记录

# insert multiple records into database
from iotdb.Session import Session
from iotdb.utils.IoTDBConstants import TSDataType, TSEncoding, Compressor

# creating session connection.
ip = "192.168.124.26"
port_ = "6667"
username_ = "root"
password_ = "root"
session = Session(ip, port_, username_, password_, fetch_size=1024, zone_id="UTC+8")
print(session.get_time_zone())
session.open(False)


measurements_list_ = [
    ["s_01", "s_02", "s_03", "s_04", "s_05", "s_06"],
    ["s_01", "s_02", "s_03", "s_04", "s_05", "s_06"],
]
values_list_ = [
    [False, 22, 33, 4.4, 55.1, "test_records01"],
    [True, 77, 88, 1.25, 8.125, "test_records02"],
]
data_types_ = [
    TSDataType.BOOLEAN,
    TSDataType.INT32,
    TSDataType.INT64,
    TSDataType.FLOAT,
    TSDataType.DOUBLE,
    TSDataType.TEXT,
]
data_type_list_ = [data_types_, data_types_]
device_ids_ = ["root.sg_test_01.d_01", "root.sg_test_01.d_01"]
session.insert_records(
    device_ids_, [2, 3], measurements_list_, data_type_list_, values_list_
)
session.close()

3.4.3 插入一个tablet

# insert multiple records into database
from iotdb.Session import Session
from iotdb.utils.IoTDBConstants import TSDataType, TSEncoding, Compressor

# creating session connection.
from iotdb.utils.Tablet import Tablet

ip = "192.168.124.26"
port_ = "6667"
username_ = "root"
password_ = "root"
session = Session(ip, port_, username_, password_, fetch_size=1024, zone_id="UTC+8")
print(session.get_time_zone())
session.open(False)


measurements_ = ["s_01", "s_02", "s_03", "s_04", "s_05", "s_06"]
data_types_ = [
    TSDataType.BOOLEAN,
    TSDataType.INT32,
    TSDataType.INT64,
    TSDataType.FLOAT,
    TSDataType.DOUBLE,
    TSDataType.TEXT,
]
# insert one tablet into the database.
values_ = [
    [False, 10, 11, 1.1, 10011.1, "test01"],
    [True, 100, 11111, 1.25, 101.0, "test02"],
    [False, 100, 1, 188.1, 688.25, "test03"],
    [True, 0, 0, 0, 6.25, "test04"],
]  # Non-ASCII text will cause error since bytes can only hold 0-128 nums.
timestamps_ = [4, 5, 6, 7]
tablet_ = Tablet(
    "root.sg_test_01.d_01", measurements_, data_types_, values_, timestamps_
)
session.insert_tablet(tablet_)
session.close()

3.4.4 插入一个numpy tablet

# insert multiple records into database
from iotdb.Session import Session
from iotdb.utils.IoTDBConstants import TSDataType, TSEncoding, Compressor
import numpy as np
# creating session connection.
from iotdb.utils.NumpyTablet import NumpyTablet
from iotdb.utils.Tablet import Tablet

ip = "192.168.124.26"
port_ = "6667"
username_ = "root"
password_ = "root"
session = Session(ip, port_, username_, password_, fetch_size=1024, zone_id="UTC+8")
print(session.get_time_zone())
session.open(False)


measurements_ = ["s_01", "s_02", "s_03", "s_04", "s_05", "s_06"]
data_types_ = [
    TSDataType.BOOLEAN,
    TSDataType.INT32,
    TSDataType.INT64,
    TSDataType.FLOAT,
    TSDataType.DOUBLE,
    TSDataType.TEXT,
]
# insert one numpy tablet into the database.
np_values_ = [
    np.array([False, True, False, True], TSDataType.BOOLEAN.np_dtype()),
    np.array([10, 100, 100, 0], TSDataType.INT32.np_dtype()),
    np.array([11, 11111, 1, 0], TSDataType.INT64.np_dtype()),
    np.array([1.1, 1.25, 188.1, 0], TSDataType.FLOAT.np_dtype()),
    np.array([10011.1, 101.0, 689.25, 6.25], TSDataType.DOUBLE.np_dtype()),
    np.array(["test01", "test02", "test03", "test04"], TSDataType.TEXT.np_dtype()),
]
np_timestamps_ = np.array([1, 2, 3, 4], TSDataType.INT64.np_dtype())
np_tablet_ = NumpyTablet(
    "root.sg_test_01.d_02", measurements_, data_types_, np_values_, np_timestamps_
)
session.insert_tablet(np_tablet_)
session.close()

3.4.5 插入一个unsorted numpy tablet

# insert multiple records into database
from iotdb.Session import Session
from iotdb.utils.IoTDBConstants import TSDataType, TSEncoding, Compressor
import numpy as np
# creating session connection.
from iotdb.utils.NumpyTablet import NumpyTablet
from iotdb.utils.Tablet import Tablet

ip = "192.168.124.26"
port_ = "6667"
username_ = "root"
password_ = "root"
session = Session(ip, port_, username_, password_, fetch_size=1024, zone_id="UTC+8")
print(session.get_time_zone())
session.open(False)

measurements_ = ["s_01", "s_02", "s_03", "s_04", "s_05", "s_06"]
data_types_ = [
    TSDataType.BOOLEAN,
    TSDataType.INT32,
    TSDataType.INT64,
    TSDataType.FLOAT,
    TSDataType.DOUBLE,
    TSDataType.TEXT,
]
# insert one unsorted numpy tablet into the database.
np_values_unsorted = [
    np.array([False, False, False, True, True], np.dtype(">?")),
    np.array([0, 10, 100, 1000, 10000], np.dtype(">i4")),
    np.array([1, 11, 111, 1111, 11111], np.dtype(">i8")),
    np.array([1.1, 1.25, 188.1, 0, 8.999], np.dtype(">f4")),
    np.array([10011.1, 101.0, 688.25, 6.25, 8, 776], np.dtype(">f8")),
    np.array(["test09", "test08", "test07", "test06", "test05"]),
]
np_timestamps_unsorted = np.array([9, 8, 7, 6, 5], np.dtype(">i8"))
np_tablet_unsorted = NumpyTablet(
    "root.sg_test_01.d_02",
    measurements_,
    data_types_,
    np_values_unsorted,
    np_timestamps_unsorted,
)
session.insert_tablet(np_tablet_unsorted)
print(np_tablet_unsorted.get_timestamps())
for value in np_tablet_unsorted.get_values():
    print(value)

3.4.6 插入多个tablet

# insert multiple records into database
from iotdb.Session import Session
from iotdb.utils.IoTDBConstants import TSDataType, TSEncoding, Compressor
import numpy as np
# creating session connection.
from iotdb.utils.NumpyTablet import NumpyTablet
from iotdb.utils.Tablet import Tablet

ip = "192.168.124.26"
port_ = "6667"
username_ = "root"
password_ = "root"
session = Session(ip, port_, username_, password_, fetch_size=1024, zone_id="UTC+8")
print(session.get_time_zone())
session.open(False)

measurements_ = ["s_01", "s_02", "s_03", "s_04", "s_05", "s_06"]
data_types_ = [
    TSDataType.BOOLEAN,
    TSDataType.INT32,
    TSDataType.INT64,
    TSDataType.FLOAT,
    TSDataType.DOUBLE,
    TSDataType.TEXT,
]
values_ = [
    [False, 10, 11, 1.1, 10011.1, "test01"],
    [True, 100, 11111, 1.25, 101.0, "test02"],
    [False, 100, 1, 188.1, 688.25, "test03"],
    [True, 0, 0, 0, 6.25, "test04"],
]  # Non-ASCII text will cause error since bytes can only hold 0-128 nums.

# insert multiple tablets into database
tablet_01 = Tablet(
    "root.sg_test_01.d_01", measurements_, data_types_, values_, [8, 9, 10, 11]
)
tablet_02 = Tablet(
    "root.sg_test_01.d_01", measurements_, data_types_, values_, [12, 13, 14, 15]
)
session.insert_tablets([tablet_01, tablet_02])
session.close()

3.4.7 插入带empty的tablet

空值会自动补。

# insert multiple records into database
from iotdb.Session import Session
from iotdb.utils.IoTDBConstants import TSDataType, TSEncoding, Compressor
import numpy as np
# creating session connection.
from iotdb.utils.NumpyTablet import NumpyTablet
from iotdb.utils.Tablet import Tablet

ip = "192.168.124.26"
port_ = "6667"
username_ = "root"
password_ = "root"
session = Session(ip, port_, username_, password_, fetch_size=1024, zone_id="UTC+8")
print(session.get_time_zone())
session.open(False)

measurements_ = ["s_01", "s_02", "s_03", "s_04", "s_05", "s_06"]
data_types_ = [
    TSDataType.BOOLEAN,
    TSDataType.INT32,
    TSDataType.INT64,
    TSDataType.FLOAT,
    TSDataType.DOUBLE,
    TSDataType.TEXT,
]
# insert one tablet with empty cells into the database.
values_ = [
    [None, 10, 11, 1.1, 10011.1, "test01"],
    [True, None, 11111, 1.25, 101.0, "test02"],
    [False, 100, 1, None, 688.25, "test03"],
    [True, 0, 0, 0, 6.25, None],
]  # Non-ASCII text will cause error since bytes can only hold 0-128 nums.
timestamps_ = [16, 17, 18, 19]
tablet_ = Tablet(
    "root.sg_test_01.d_01", measurements_, data_types_, values_, timestamps_
)
session.insert_tablet(tablet_)
session.close()

3.4.8 插入一个设备的数据

会覆盖以前的数据

# insert multiple records into database
from iotdb.Session import Session
from iotdb.utils.IoTDBConstants import TSDataType, TSEncoding, Compressor
import numpy as np
# creating session connection.
from iotdb.utils.NumpyTablet import NumpyTablet
from iotdb.utils.Tablet import Tablet

ip = "192.168.124.26"
port_ = "6667"
username_ = "root"
password_ = "root"
session = Session(ip, port_, username_, password_, fetch_size=1024, zone_id="UTC+8")
print(session.get_time_zone())
session.open(False)

# insert records of one device
time_list = [1, 2, 3]
measurements_list = [
    ["s_01", "s_02", "s_03"],
    ["s_01", "s_02", "s_03"],
    ["s_01", "s_02", "s_03"],
]
data_types_list = [
    [TSDataType.BOOLEAN, TSDataType.INT32, TSDataType.INT64],
    [TSDataType.BOOLEAN, TSDataType.INT32, TSDataType.INT64],
    [TSDataType.BOOLEAN, TSDataType.INT32, TSDataType.INT64],
]
values_list = [[False, 22, 33], [True, 1, 23], [False, 15, 26]]

session.insert_records_of_one_device(
    "root.sg_test_01.d_01", time_list, measurements_list, data_types_list, values_list
)
session.close()

3.5 执行sql

3.5.1 执行非查询语句sql

from iotdb.Session import Session

ip = "192.168.124.26"
port_ = "6667"
username_ = "root"
password_ = "root"
session = Session(ip, port_, username_, password_, fetch_size=1024, zone_id="UTC+8")
print(session.get_time_zone())
session.open(False)

# execute non-query sql statement
session.execute_non_query_statement(
    "insert into root.sg_test_01.d_01(timestamp, s_02) values(16, 188)"
)
session.close()

3.5.2 执行查询语句sql

from iotdb.Session import Session

ip = "192.168.124.26"
port_ = "6667"
username_ = "root"
password_ = "root"
session = Session(ip, port_, username_, password_, fetch_size=1024, zone_id="UTC+8")
print(session.get_time_zone())
session.open(False)

# execute sql query statement
#sql_str = "select * from root.sg_test_01.d_01"
sql_str = "select s_01, s_02, s_03, s_04, s_05, s_06 from root.sg_test_01.d_02"
with session.execute_query_statement(sql_str) as session_data_set:
    session_data_set.set_fetch_size(1024)
    while session_data_set.has_next():
        print(session_data_set.next())
session.close()

3.5.3 查询后转换为df

from iotdb.Session import Session
import pandas as pd
ip = "192.168.124.26"
port_ = "6667"
username_ = "root"
password_ = "root"
session = Session(ip, port_, username_, password_, fetch_size=1024, zone_id="UTC+8")
print(session.get_time_zone())
session.open(False)

# execute sql query statement
sql_str = "select * from root.sg_test_01.d_01"

with session.execute_query_statement(sql_str) as session_data_set:
    df = session_data_set.todf()
session.close()

4 整体测试

4.1 写入记录并查询

写入后时间戳会减去8小时，读取后正常。
在这里插入图片描述

from iotdb.Session import Session
# creating session connection.
from iotdb.utils.IoTDBConstants import TSDataType, TSEncoding, Compressor
import time
from datetime import datetime
# 字符串时间戳转换为整数时间戳
def tostamp_int(timestr):
    datetime_obj = datetime.strptime(timestr, "%Y-%m-%d %H:%M:%S.%f")
    obj_stamp = int(time.mktime(datetime_obj.timetuple()) * 1000.0 + datetime_obj.microsecond / 1000.0)
    return obj_stamp


ip = "192.168.124.26"
port_ = "6667"
username_ = "root"
password_ = "root"
session = Session(ip, port_, username_, password_, fetch_size=1024)
print(session.get_time_zone())
session.open(False)

devid = "667601E99"
pointid = "01"
kpiid = "环境温度"
timestr1 = "2022-08-31 13:18:55.786"
timestr2 = "2022-08-31 13:18:56.505"
ts_path = "root.main.{}.{}.{}".format(devid,pointid,kpiid)


# 创建存储组
session.set_storage_group("root.main")
# 创建时间序列
session.create_time_series(ts_path, TSDataType.FLOAT, TSEncoding.PLAIN, Compressor.SNAPPY)

# 插入多条记录
measurements_list_ = [
    ["环境温度"],
    ["环境温度"],
]
values_list_ = [
    [35.6],
    [23.8],
]

data_types_ = [TSDataType.FLOAT]
data_type_list_ = [data_types_, data_types_]
device_ids_ = ["root.main.667601E99.01", "root.main.667601E99.01"]

session.insert_records(
    device_ids_, [tostamp_int(timestr1), tostamp_int(timestr2)], measurements_list_, data_type_list_, values_list_
)

print(tostamp_int(timestr1),tostamp_int(timestr2))
# execute sql query statement
sql_str = "select * from root.main"

with session.execute_query_statement(sql_str) as session_data_set:
    df = session_data_set.todf()
print(df)
session.close()

4.2 sql写入并查询

from iotdb.Session import Session
# creating session connection.
from iotdb.utils.IoTDBConstants import TSDataType, TSEncoding, Compressor
import time
from datetime import datetime
# 字符串时间戳转换为整数时间戳
def tostamp_int(timestr):
    datetime_obj = datetime.strptime(timestr, "%Y-%m-%d %H:%M:%S.%f")
    obj_stamp = int(time.mktime(datetime_obj.timetuple()) * 1000.0 + datetime_obj.microsecond / 1000.0)
    return obj_stamp


ip = "192.168.124.26"
port_ = "6667"
username_ = "root"
password_ = "root"
session = Session(ip, port_, username_, password_, fetch_size=1024)
print(session.get_time_zone())
session.open(False)

devid = "667601E99"
pointid = "01"
kpiid = "环境温度"
timestr1 = "2022-08-31 14:18:55.786"
ts_path = "root.main.{}.{}.{}".format(devid,pointid,kpiid)


# 创建存储组
session.set_storage_group("root.main")
# 创建时间序列
session.create_time_series(ts_path, TSDataType.FLOAT, TSEncoding.PLAIN, Compressor.SNAPPY)

# execute no sql query statement
sql_str = "insert into root.main.667601E99.01(timestamp,{}) values({},{})".format(kpiid,tostamp_int(timestr1),67.8)
print(sql_str)
session.execute_non_query_statement(sql_str)

# execute sql query statement
sql_str = "select * from root.main"
with session.execute_query_statement(sql_str) as session_data_set:
    df = session_data_set.todf()
print(df)
session.close()

本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系:hwhale#tublm.com(使用前将#替换为@)

IotDB

python3

时序数据库

时序数据库-4-[IoTDB]的python3操作的相关文章

python中的优先队列PriorityQueue

普通的队列是一种先进先出的数据结构元素在队列尾追加而从队列头删除在优先队列中元素被赋予优先级当访问元素时具有最高优先级的元素最先删除优先队列具有最高级先出的行为特征通常采用堆数据结构来实现我们可以利用优先队列中元素被赋予优
Debian12中为python3配置虚拟环境及在Pycharm中使用虚拟环境

在Debian 12中 python默认为python 3 11 基于应用现需设置虚拟环境 1 安装venv模块从python3 3开始配置python虚拟环境可用venv模块更加方便了执行命令 apt install pyth
【Y 新闻】YMatrix携手三一集团，荣获“2023爱分析·数据库最佳实践案例”

2023 年 8 月 16 日由爱分析主办的第五届数据智能高峰论坛在北京 JW 万豪酒店成功举办本次论坛以激活数据资产释放数据价值为主题聚焦企业在数据能力和数据应用建设过程中所面临的系列问题会上由 YMatrix 与三一集团
使用 selenium 连接已经打开的 chrome 浏览器

1 方法一新建文件夹test 进入chrome exe 目录打开CMD 输入 chrome exe remote debugging port 9999 user data dir D test 弹出浏览器框 pycharm运行脚本如
神经网络模型量化

量化模型 Quantized Model 是一种模型加速 Model Acceleration 方法的总称包括二值化网络 Binary Network 三值化网络 Ternary Network 深度压缩 Deep Compression
ERROR: No matching distribution found for Django 报错解决

ERROR No matching distribution found for Django 报错解决今天安装一个 python 依赖时执行 pip install r requirements txt后界面出现ERROR No m
python-6-for循环及格式化输出format三种用法

前言循环我们前面讲过了无限循环那么for循环属于什么循环呢显然就是有限循环另外格式化输出我们前面也讲过但是format也能做到不一样的格式化输出一起看看吧一 for 循环 1 for 有限循环 for 有限循环 s 123as
MatrixDB 从4018个参赛项目中脱颖而出，获 HICOOL 全球创业大赛

MatrixDB 又获奖了聚焦全球创新创业趋势的 HICOOL 2021 全球创业大赛历时145天的激烈角逐遍布全球84个国家和地区 4018个参赛项目 5077名创业人才报名参加作为今年最火热的国际化创业赛事北京四维纵横数据技术
基于opencv的家居智能安防机器视觉系统

基于opencv的家居智能安防机器视觉系统关键词 Windows 树莓派 python opencv 1 写在前面的话大学4年很快过去了因为疫情原因我们从大四上学期结束之后直接跳到了大学的尾声毕业设计毕业答辩毕业的环境回顾整个
如何在 CentOS/RHEL 7 和 Fedora 上安装 Python 3.9

Python 是一种非常流行用途广泛且易于学习的编程语言广泛应用于从 Web 开发和数据分析到人工智能和机器学习的各个行业和应用程序 Python 3 9 是该语言的最新版本之一提供了改进的性能和许多新功能在本教程中我们将指导您完
神经网络预测彩票数据

一人工智能深度学习神经网络在双色球彩票中的应用研究一 https www cnblogs com zdz8207 p DeepLearning NeuralNetworks html 二百度AI http ai baidu com p
OpenCV中的人脸活体检测和身份认证如何实现？OpenCV人脸识别

本文将介绍如何在OpenCV中实现人脸活体检测和身份认证结合人脸检测关键点定位和深度学习模型我们可以有效地检测和区分真实人脸和照片视频等非真实生物特征以实现可靠的身份认证和活体检测人脸检测和关键点定位使用OpenCV提供的人脸
还在写代码处理映射关系？动动手指，MatrixDB 4.4 轻松让 JSON 入表

MatrixDB 4 4 已于今日正式发布 4 4 版本修复了过往大规模生产环境实践中遇到的性能和兼容性等问题全面提升产品稳定性新版本有3个值得重点关注的特性 MatrixGate 再升级 UPSERT 功能支持去重新增请求超时时间
python3 with.py

模块 python3 with py 参考 https docs python org zh cn 3 reference compound stmts html with https docs python org zh cn 3 ref
Python3 如何优雅地使用正则表达式（详解四）

更多强大的功能到目前为止我们只是介绍了正则表达式的一部分功能在这一篇中我们会学习到一些新的元字符然后再教大家如何使用组来获得被匹配的部分文本更多元字符还有一些元字符我们没有讲到接下来小甲鱼一一为大家讲解有些元字符它们不匹配
Python 一篇入门

目录 Python 的简介与特点 Python支持多种编程风格解释运行跨平台可扩展强可嵌入丰富的库 Python版本选择 Python开发环境搭建认识Python解释器快速入门变量和赋值动态类型变量命名规则认识数字
Python3 如何优雅地使用正则表达式（详解五）

非捕获组命名组精心设计的正则表达式可能会划分很多组这些组不仅可以匹配相关的子串还能够对正则表达式本身进行分组和结构化在复杂的正则表达式中由于有太多的组因此通过组的序号来跟踪和使用会变得困难有两个新的功能可以帮你解决这个问题非
centos7 pip3 安装python模块包报错解决

centos7 pip3 安装python模块包报错 bash usr local bin pip3 usr local bin python3 6 坏的解释器没有那个文件或目录 root localhost Python pip3 in
CnosDB有主复制演进历程

分布式存储系统的复杂性涉及数据容灾备份一致性高并发请求和大容量存储等问题本文结合CnosDB在分布式环境下的演化历程分享如何将分布式理论应用于实际生产以及不同实现方式的优缺点和应用场景分布式系统架构模式分布式存储系统下按照数据
从 MySQL 到 DolphinDB，Debezium + Kafka 数据同步实战

Debezium 是一个开源的分布式平台用于实时捕获和发布数据库更改事件它可以将关系型数据库如 MySQL PostgreSQL Oracle 等的变更事件转化为可观察的流数据以供其他应用程序实时消费和处理本文中我们将采用 De

随机推荐

无人机地面站QT版

下载链接源代码
利用递归函数调用方式，将所输入的5个字符，以相反顺序打印出来

span class hljs keyword void span func span class hljs keyword int span n span class hljs keyword void span main span cl
低通滤波（一阶）

1 一阶滤波算法的原理一阶滤波 xff0c 又叫一阶惯性滤波 xff0c 或一阶低通滤波是使用软件编程实现普通硬件RC低通滤波器的功能一阶低通滤波的算法公式为 xff1a Y n 61 1 Y n 1 43 X n 式中 xff1a
I2C初始化

一管脚初始化由于STM32的硬件初始化比较复杂 xff0c 这里我们采用软件初始化 xff0c 选用端口PB6 PB7 以匿名的I2C初始化程序为例 span class hljs comment I2C GPIO定义 span spa
四轴思路（持续更新）

遥控器 xff1a 发送数据 MPU6050 xff1a 加速度做一维卡尔曼滤波 xff0c 角速度做一介低通滤波然后四元数姿态解算接着串级PID控制平衡 xff0c 外环角度环 xff0c 内环角速度环高度控制 xff1a 高度和速
QT 上位机（网络通信）

Client类 span class hljs comment span class hljs xmlDocTag span span class hljs xmlDocTag span span class hljs xmlDocTag
win10系统如何通过ssh远程登录另一台电脑的deepin linux系统

1 首先 xff0c 更新一下软件源 xff0c 打开终端窗口 xff0c 输入 sudo apt get update 2 然后 xff0c 在终端中 xff0c 输入 sudo apt get install openssh serv
基于STM32与ESP8266的太空人WiFi天气时钟（代码开源）

前言 xff1a 本文为手把手教学ESP8266著名开源项目太空人WiFi天气时钟 xff0c 不同的是本次项目采用的是STM32 作为MCU 两者开发过程中有因为各自芯片的特点 xff08 时钟频率 xff0c 内存大小等 xff09
make menuconfig错误的解决办法

如果使用make menuconfig的方式配置内核 xff0c 又碰巧系统没有安装ncurses库 xff08 ubuntu系统默认就没有安装此库 xff09 xff0c 就会出现错误 xff0c 错误信息大体上如下 xff1a Una
FileZilla以root用户登录Linux

一首先创建root用户的密码 span class hljs built in sudo span passwd root 然后输入要设置的密码 xff0c 然后再输入一次 xff0c 成功 xff01 二修改配置文件 filezila
px4编译

如果下载速度特别慢 xff0c 可以使用手机的4G网络位置确定 mkdir p src cd src 开始下载指定版本的px4 xff0c 在这里是v1 8 2版本 git clone b v1 8 2 https github com
px4源码----位置估算（position_estimator_inav_params.h）

pragma once include lt parameters param h gt struct position estimator inav params float w z baro 权重 z轴气压计位置 0 5 float
ubuntu如何把调整cpu策略

一安装cpu频率管理软件 sudo apt get install cpufrequtils 二查看cpu当前状态 cpufreq info 其中available cpufreq governors xff1a performance
树莓派系统介绍

树莓派是一个微型计算机 xff0c 和普通的电脑没有什么区别 xff0c 只是体积更小 xff0c 只有卡片大小 xff0c 存储能力和计算能力会差一点 xff0c 主要用于学习 xff0c 实验所用是电脑就要安装操作系统 xff0c 树
小觅摄像头ROS编译错误

GitHub slightech MYNT EYE ORB SLAM2 Sample Forked from ORB SLAM2 https github com raulmur ORB SLAM2 Forked from ORB SLAM
华为路由器交换机常用命令（随时补充更新）

一视图切换 lt huawei gt 用户视图 huawei 系统视图 xff0c 在用户视图状态下输入sys进入 xff0c 在系统视图下输入quit或者return返回用户视图 huawei g0 0 1 端口视图 xff0c 从系统
01路径规划问题的相关理论

目录 1 旅行商问题 2 有能力约束的车辆路径问题 3 车辆路径主要要素特征 4 约束条件分析 5 带时间窗的车辆路径问题 6 车辆路径问题求解算法 7 小节 1 旅行商问题旅行商问题 xff08 Traveling Saleman Pr
时序数据库-3-[IoTDB]的安装与使用

IoTDB官方文档手册 Apache IoTDB xff08 物联网数据库 xff09 是一体化收集存储管理与分析物联网时序数据的软件系统 Apache IoTDB 采用轻量式架构 xff0c 具有高性能和丰富的功能 xff0c 并与A
【强烈推荐】基于STM32的TFT-LCD各种显示实现（内容详尽含代码）

前言 xff1a TFT LCD模块作为人们日常生活中常见屏幕类型之一 xff0c 使用的受众面非常广阔例如 xff1a 显示各个传感器数值 xff0c 显示精美界面 xff0c 多级化菜单系统等等都不离不开他的身影可以说学会TFT L
时序数据库-4-[IoTDB]的python3操作

从采集到存储 xff1a 时序数据库到底怎么处理时间 xff1f iotdb官方文档手册 1 容器安装iotdb 可以使用docker volume create命令创建 docker 卷此命令将在 var lib docker volu