背景和痛点

为什么选择 TDengine TSDB

• 高效数据接入能力：支持 MQTT 数据写入方式，可通过低代码方式快速接入业务平台，实现高并发数据写入，确保近万台传感器上报数据的完整与可靠。
• 强大的流式计算能力：具备实时数据聚合与分析能力，能够对上报的时序元数据进行整合并高效供给业务平台，同时通过多副本机制保障数据高效写入与可靠备份。
• 完善的技术支持体系：提供一对一、7×24 小时技术支持服务，确保项目在开发、部署及运维阶段的稳定运行。
• 国产化与生态兼容性：作为 100% 自主可控的时序数据库， TDengine TSDB 符合信创标准，并已与华为云、麒麟软件等生态厂商完成深度集成，满足极企科技在国产化替代中的技术选型需求。
• 领先的综合性能与可拓展性：在同类型数据库中，TDengine TSDB 在数据压缩率、写入速度、分析效率及分布式架构等方面表现突出，后续版本还将持续增强易用性与 AI 能力，支持更多的功能和场景，助力企业进一步提升应用效果。

TDengine TSDB 落地实践

架构描述

1. 各类传感器采集的数据首先由 Node-Red 进行预处理后写入 EMQ 消息中间件；
2. TDengine TSDB 通过 taosX 模块从 EMQ 中高效读取并存储数据，实现时序数据的集中管理；
3. EMQ 再通过 Restful / WebSocket 接口从 TDengine TSDB 获取所需数据，为上层业务应用与可视化系统提供实时访问能力。

智能应用场景示例

• 当指定区域内连续 5 分钟无人时，系统自动关闭照明；
• 当某项监测指标超过设定阈值时，自动触发告警并记录相关信息；
• 当检测到某区域无人时，系统自动关闭空调以节约能源。

数据库建模

1. 超级表定义

CREATE STABLE IF NOT EXISTS airsensor (
  ts timestamp,        时间
  pm25 int,        PM2.5
  pm10 int,        PM1.0
  tvoc int,                TVOC
  co2 int,                二氧化碳
  formaldehyde float,        甲醛
  noise float,        噪音
  temperature float,                温度
  humidity float,        湿度
  light int,                光照
  h2s int,                硫化氢
  ch4 int,                甲烷
  co int,                一氧化碳
  no2 float,        二氧化氮
  h2 int,                氢气
  odor float        异味
) TAGS (
  position NCHAR(200),
  space NCHAR(20),
  floor_area NCHAR(20),
  floor NCHAR(20),
  area NCHAR(20),
  device_code NCHAR(20),
  device_id int,
  factory NCHAR(50),
  model NCHAR(50)
);

1. 流计算
   1. 会议室人员判定

   create stream if not exists mroom_stream trigger at_once into mroom_stream_status (ts,status) tags(
       space,
       floor_area,
       floor,
       area 
   ) subtable(
       cast(
           concat('mss_', space, '_', floor_area, '_', floor, '_', area) as varchar
       )
   ) as
   SELECT
       _wstart as ts,
       case
           when sum(status) > 0 then 1
           else 0
       end as status
   FROM
       bxserver.humensensor partition by space,
       floor_area,
       floor,
   area interval(1m) fill(value,-1);

select _wstart as ts, max(total_kwh)-min(total_kwh) as used from bxserver.powersensor partition by tbname interval(1d);

1. 订阅数据

落地效果

• 针对电量传感器采集的元数据通过 TDengine TSDB 转换后的每个楼层用电量统计如下：

• 针对每个设备状态上报数据通过 TDengine TSDB 转化为设备告警情况如下：

• 针对空气传感器采集的数据，系统通过 TDengine TSDB 进行转换与分析，并根据当前区域的平均温度执行相应的温控策略：

TDengine 应用经验分享

1. 时钟同步问题

1. 查询 SQL 语句优化

select TO_CHAR(_wstart, 'YYYY/MM/DD HH24:MI:00') as ts, TO_CHAR(_wstart, 'HH24') as hour, sum(kwh) as kwh, space,floor_area,floor,type from (select _rowts as ts, diff(kwh) as kwh, space, floor_area, floor, area, device_id, loop, type frombxserver.powersensor_loop partition by space, floor_area, floor, area, device_id, loop, type) where ts >= TO_UNIXTIMESTAMP('2025-08-28 00:00:00') and ts <= TO_UNIXTIMESTAMP('2025-08-28 23:59:59') partition by space, floor_area, floor, type interval(1d) order by floor asc;

select TO_CHAR(_wstart, 'YYYY/MM/DD HH24:MI:00') as ts, TO_CHAR(_wstart, 'HH24') as hour, sum(kwh) as kwh, space,floor_area,floor,type from (select _rowts as ts, diff(kwh) as kwh, space, floor_area, floor, area, device_id, loop, type frombxserver.powersensor_loop where ts >= TO_UNIXTIMESTAMP('2025-08-28 00:00:00') and ts <= TO_UNIXTIMESTAMP('2025-08-28 23:59:59') partition by space, floor_area, floor, area, device_id, loop, type) partition by space, floor_area, floor, type interval(1d) order by floor asc;

未来规划

关于成都极企科技

关于作者