网站文章没有被收录,数字广东公司面试严吗,多媒体展厅设计制作公司,北京海淀的公司本章以智能电表的数据模型为例介绍如何在 TDengine 中使用 SQL 来写入、更新、删除时序数据。
写入
在 TDengine 中#xff0c;用户可以使用 SQL 的 insert 语句写入时序数据。
一次写入一条
假设设备 ID 为 d1001 的智能电表在 2018 年 10 月 3 日 14:38:05 采集到数据用户可以使用 SQL 的 insert 语句写入时序数据。
一次写入一条
假设设备 ID 为 d1001 的智能电表在 2018 年 10 月 3 日 14:38:05 采集到数据电流 10.3A电压 219V相位 0.31。在 power 数据库中创建了属于超级表 meters 的子表 d1001 后可以通过下面的 insert 语句在子表 d1001 中写入时序数据。
可以通过下面的 INSERT 语句向子表 d1001 中写入时序数据。
insert into d1001 (ts, current, voltage, phase) values ( 2018-10-03 14:38:05, 10.3, 219, 0.31)上面的 SQL 向子表 d1001 的 ts, current, voltage, phase 这 4 列分别写入 2018-10-03 14:38:05, 10.3, 219, 0.31。
当 INSERT 语句中的 VALUES 部分包含了表的所有列时可以省略 VALUES 前的字段列表如下面的 SQL 语句所示其与前面指定列的 INSERT 语句效果完全一样。
insert into d1001 values(2018-10-03 14:38:05, 10.3, 219, 0.31)对于表的时间戳列第一列也可以直接使用数据库精度的时间戳。
INSERT INTO d1001 VALUES (1538548685000, 10.3, 219, 0.31);以上三种 SQL 的效果完全相同。
一次写入多条
假设设备 ID 为 d1001 的智能电表每 10s 采集一次数据每 30s 上报一次数据即每 30s 需要写入 3 条数据。用户可以在一条 insert 语句中写入多条记录。如下 SQL 一共写入了 3 条数据。
insert into d1001 values( 2018-10-03 14:38:05, 10.2, 220, 0.23),( 2018-10-03 14:38:15, 12.6, 218, 0.33),( 2018-10-03 14:38:25, 12.3, 221, 0.31)上面的 SQL 一共写入了三条数据。
一次写入多表
假设设备 ID 为 d1001、d1002、d1003 的 3 台智能电表都是每 30 秒需要写入 3 条数据。对于这种情况TDengine 支持一次向多个表写入多条数据。
INSERT INTO d1001 VALUES (2018-10-03 14:38:05, 10.2, 220, 0.23),(2018-10-03 14:38:15, 12.6, 218, 0.33),(2018-10-03 14:38:25, 12.3, 221, 0.31)
d1002 VALUES (2018-10-03 14:38:04, 10.2, 220, 0.23),(2018-10-03 14:38:14, 10.3, 218, 0.25),(2018-10-03 14:38:24, 10.1, 220, 0.22)
d1003 VALUES(2018-10-03 14:38:06, 11.5, 221, 0.35),(2018-10-03 14:38:16, 10.4, 220, 0.36),(2018-10-03 14:38:26, 10.3, 220, 0.33)
;上面的 SQL 一共写入了九条数据。
指定列写入
可以通过指定列向表的部分列写入数据。SQL 中没有出现的列数据库将自动填充为空值NULL。注意时间戳列必须存在且值不能为空。如下 SQL 向子表 d1004 写入了一条数据。这条数据只包含电压和相位电流值为 NULL。
insert into d1004 (ts, voltage, phase) values(2018-10-04 14:38:06, 223, 0.29)写入时自动建表
用户可以使用带有 using 关键字的自动建表语句进行写入。当子表不存在时先触发自动建表再写入数据当子表已经存在时则直接写入。使用自动建表的 insert 语句也可以通过指定部分标签列进行写入未被指定的标签列的值为空值NULL。如下 SQL 写入一条数据。当子表 d1005 不存在时先自动建表标签 group_id 的值为 NULL再写入数据
insert into d1005
using meters (location)
tags ( beijing.chaoyang)
values ( 2018-10-04 14:38:07, 10.15, 217, 0.33)自动建表的 insert 语句也支持在一条语句中向多张表写入数据。如下 SQL 使用自动建表的 insert 语句共写入 9 条数据。
INSERT INTO d1001 USING meters TAGS (California.SanFrancisco, 2) VALUES (2018-10-03 14:38:05, 10.2, 220, 0.23),(2018-10-03 14:38:15, 12.6, 218, 0.33),(2018-10-03 14:38:25, 12.3, 221, 0.31)
d1002 USING meters TAGS (California.SanFrancisco, 3) VALUES (2018-10-03 14:38:04, 10.2, 220, 0.23),(2018-10-03 14:38:14, 10.3, 218, 0.25),(2018-10-03 14:38:24, 10.1, 220, 0.22)
d1003 USING meters TAGS (California.LosAngeles, 2) VALUES(2018-10-03 14:38:06, 11.5, 221, 0.35),(2018-10-03 14:38:16, 10.4, 220, 0.36),(2018-10-03 14:38:26, 10.3, 220, 0.33)
;通过超级表写入
TDengine 还支持直接向超级表写入数据。需要注意的是超级表是一个模板本身不存储数据写入的数据是存储在对应的子表中。如下 SQL 通过指定 tbname 列向子表 d1001 写入一条数据。
insert into meters (tbname, ts, current, voltage, phase, location, group_id)
values(d1001, 2018-10-03 14:38:05, 10.2, 220, 0.23, California.SanFrancisco, 2)通过虚拟表写入
TDengine 不支持向虚拟表或虚拟超级表写入因为虚拟表或虚拟超级表是动态生成的本身不存储数据。
零代码写入
为了方便用户轻松写入数据TDengine 已与众多知名第三方工具实现无缝集成包括 Telegraf、Prometheus、EMQX、StatsD、collectd 和 HiveMQ 等。用户只须对这些工具进行简单的配置便可轻松将数据导入 TDengine。此外TDengine Enterprise 还提供了丰富的连接器如 MQTT、OPC、AVEVA PI System、Wonderware、Kafka、MySQL、Oracle 等。通过在 TDengine 端配置相应的连接信息用户无须编写任何代码即可高效地将来自不同数据源的数据写入 TDengine。
更新
可以通过写入重复时间戳的一条数据来更新时序数据新写入的数据会替换旧值。下面的 SQL通过指定列的方式向子表 d1001 中写入 1 行数据当子表 d1001 中已经存在日期时间为 2018-10-03 14:38:05 的数据时current电流的新值 22会替换旧值。
INSERT INTO d1001 (ts, current) VALUES (2018-10-03 14:38:05, 22);删除
为方便用户清理由于设备故障等原因产生的异常数据TDengine 支持根据时间戳删除时序数据。下面的 SQL将超级表 meters 中所有时间戳早于 2021-10-01 10:40:00.100 的数据删除。数据删除后不可恢复请慎重使用。为了确保删除的数据确实是自己要删除的建议可以先使用 select 语句加 where 后的删除条件查看要删除的数据内容确认无误后再执行 delete。
delete from meters where ts 2021-10-01 10:40:00.100 ;访问官网
更多内容欢迎访问 TDengine 官网
