You are viewing an old version of this page. View the current version.

Compare with Current View Page History

« Previous Version 10 Next »

一、数据模型

1、物理量（Measurement，也称工况、字段 field）

物理量，是在实际场景中检测装置所记录的测量信息，且可以按一定规律变换成为电信号或其他所需形式的信息输出并发送给 IoTDB。在 IoTDB 当中，存储的所有数据及路径，都是以物理量为单位进行组织。

2、实体（Entity，也称设备，device）

一个物理实体，是在实际场景中拥有物理量的设备或装置。在 IoTDB 当中，所有的物理量都有其对应的归属实体。

3、存储组（Storage group）

一组物理实体，用户可以将任意前缀路径设置成存储组。

4、数据点（Data point）

一个“时间-值”对。

5、时间序列（一个实体的某个物理量对应一个时间序列，Timeseries，也称测点 meter、时间线 timeline，实时数据库中常被称作标签 tag、参数 parameter）

一个物理实体的某个物理量在时间轴上的记录，是数据点的序列。

6、对齐的时间序列（Aligned timeseries）

在实际应用中，存在某些实体的多个物理量同时采样（如 GPS 的经度和维度），形成具有相同时间戳的多条时间序列，称这些时间序列是对齐的。对齐时间序列的时间戳列在内存和磁盘中仅需存储一次，可以减少存储资源的占用。

对齐的多个时间序列需要同时创建，使用关键字 aligned 显式声明，后续可以删除其中某列，但不能新增列。

查询数据时，可以对于每一条时间序列单独查询。

插入数据时，对齐的时间序列中某列的某些行允许有空值。

7、物理量模板（Schema template）

实际应用中有许多实体所采集的物理量相同，即具有相同的工况名称和类型，可以声明一个物理量模板来定义可采集的物理量集合。在实践中，物理量模板的使用可帮助减少元数据的资源占用。

二、应用场景

场景1：一个物理实体具有多个非对齐的时间序列

// 创建时间序列
// 1. 完整语法（v0.12及之前）
create timeseries root.sg1.d1.s1 with datatype=FLOAT, encoding=RLE, compression=SNAPPY, tags(tag1=v1, tag2=v2), attributes(attr1=v1, attr2=v2)
create timeseries root.sg1.d1.s2 with datatype=FLOAT, encoding=RLE, compression=SNAPPY, tags(tag1=v1, tag2=v2), attributes(attr1=v1, attr2=v2)

// 2. 简化语法（v0.13开始支持，与之前语法兼容）
create timeseries root.sg1.d1.s1 FLOAT encoding=RLE compression=SNAPPY tags(tag1=v1, tag2=v2) attributes(attr1=v1, attr2=v2)
create timeseries root.sg1.d1.s2 FLOAT encoding=RLE compression=SNAPPY tags(tag1=v1, tag2=v2) attributes(attr1=v1, attr2=v2)

// 插入语句
insert into root.sg1.d1(time, s1) values(1,1)
insert into root.sg1.d1(time, s1, s2) values(1,1,2)

场景2：一个物理实体具有一组对齐的时间序列

// 在实体 root.sg1.d2 下创建一组对齐的时间序列
create aligned timeseries root.sg1.d2.(s1 FLOAT encoding=RLE, s2 INT32 encoding=Grollia compression=SNAPPY) compression=SNAPPY

// 注：
// 1.可以指定每条时间序列的编码(encoding)和压缩方式(compression)，但是暂不支持指定别名(alias)，props, attributes, tags 等。
// 2.未指定 compression 的时间序列，则采用系统默认配置；小括号外的 compression 定义时间列压缩方式和未显式声明的列的压缩方式。

// 插入语句
insert into root.sg.d2(time, s1, s2) values(1, 1, 2)
insert into root.sg.d2(time, s1) values(2, 1)  //允许单独写某条时间序列，其他时间序列在该时间点上为空值

// 场景2所创建的对齐时间序列所属物理实体可以扩充时间序列，但需要在该物理实体下嵌套新实体。
// 例如，可以向d2下继续添加时间序列： 
create timeseries root.sg1.d2.t1.s1 FLOAT
create timeseries root.sg1.d2.v1.(s1 FLOAT, s2 FLOAT)

场景4：一个物理设备具有多个多元序列

// 创建语句
create [aligned] timeseries root.sg.d3.陀螺仪(s1 FLOAT, s2 INT32)
create [aligned] timeseries root.sg.d3.GPS(s3 FLOAT, s4 INT32)


// 插入语句
insert into root.sg.d3(time, 陀螺仪(s1, s2), GPS(s3, s4)) values(1, (1, 2),(3,4))
insert into root.sg.d3(time, 陀螺仪(s1, s2)) values(1, (1, 2))


// 查询语句
select s1,s2 from root.sg.d3.陀螺仪
select * from root.sg.d3.陀螺仪
select 陀螺仪.* from root.sg.d3
select 陀螺仪.s1 from root.sg.d3
select d3.* from root.sg

注意：场景4所创建的多元时间序列是可以扩充的。例如，可以向d3下继续添加其他的一元或多元时间序列：

create timeseries root.sg.d3.s3 FLOAT


场景5：一个物理设备具有混合的多元序列和一元序列

// 创建语句
create [aligned] timeseries root.sg.d4.GPS(s3 FLOAT, s4 INT32)
create timeseries root.sg.d4.s5 FLOAT


// 插入语句
insert into root.sg.d3(time, GPS(s3, s4), s5) values(1, (3,4), 5)

三、Session API

注意：以下仅展示本次新增的 session API，其他 API 与旧有 API 相同的不在此展示，如：查询语句（executeRawDataQuery）。

1、多元时间序列相关 API

// 创建多元时间序列
void createAlignedTimeseries(
    String prefixPath, // "root.sg.d1.陀螺仪"
    List<String> measurements,
    List<TSDataType> dataTypes,
    List<TSEncoding> encodings,
    CompressionType compressor,
    List<String> measurementAliasList
);

2、插入Record

一个 Record 是一个设备一个时间戳下多个测点的数据，例如：

insert into root.sg.d3(time, 陀螺仪(s1, s2)) values(1,(1,2))

API 如下：

// 服务器需要做类型推断，可能会有额外耗时
void insertAlignedRecord(String prefixPath, long time, List<String> measurements, List<String> values)


// 提供数据类型后，服务器不需要做类型推断，可以提高性能
void insertAlignedRecord(String prefixPath, long time, List<String> measurements, List<TSDataType> types, List<Object> values

应用到上面的例子即：

void insertAlignedRecord(
    "root.sg.d3.陀螺仪",
    1,
    Arrays.asList("s1", "s2"),
    Arrays.asList("1", "2")
)


注意：当前仅支持 record 插入一个多元时间序列。后期将适配如下 SQL（即在同一个 record 中涉及多个多元时间序列、或涉及混合的一元和多元时间序列）

insert into root.sg.d3(time, 陀螺仪(s1, s2), GPS(s3, s4)) values(1, (1, 2),(3,4))

3、插入Tablet

Tablet 是一个设备若干行非空数据块，每一行的列都相同

// 插入一个 Tablet
void insertTablet(Tablet tablet)


// 插入多个 Tablet
void insertTablets(Map<String, Tablet> tablet)


多元时间序列通过 VectorMeasurementSchema 构建 Tablet

List<IMeasurementSchema> schemaList = new ArrayList<>(); schemaList.add( new VectorMeasurementSchema( new String[] {"s1", "s2"}, new TSDataType[] {TSDataType.INT64, TSDataType.INT32})); Tablet tablet = new Tablet("root.sg1.d1.GPS", schemaList);


Tablet支持某列的某一行是null？（单元、多元保持统一）


TODO：更新下面的API描述

//多元序列允许某列的某些行有空值，如时间戳2下只有s1有值，s2无值，则只需：

insert into root.sg.d1(time, b(s1)) values(2,(1))

//上述例子也可以通过null显式声明：

insert into root.sg.d1(time, b(s1, s2)) values(2,(1, null))


//多元序列允许各列独自写入：

insert into root.sg.d1(time, b(s1)) values(3,(1))

insert into root.sg.d1(time, b(s2)) values(3,(2))



  • No labels