TDengine 深度评测

CREATE STABLE device_data (
  ts TIMESTAMP, value FLOAT, quality INT
) TAGS (device_type NCHAR(20), workshop NCHAR(20));

CREATE TABLE press_001 USING device_data
  TAGS ('冲床', '一车间');

# 批量写入（推荐）
INSERT INTO press_001 VALUES
  ('2026-10-14 10:00:00.000', 25.6, 1),
  ('2026-10-14 10:00:01.000', 25.8, 1),
  ('2026-10-14 10:00:02.000', 25.5, 1);

# 超级表批量写入
INSERT INTO device_data
  (device_type, workshop) VALUES
  ('冲床','一车间', '2026-10-14 10:00:00', 25.6, 1),
  ('冲床','二车间', '2026-10-14 10:00:00', 26.1, 1);

# 最新值查询（<1ms，走缓存）
SELECT last(value) FROM device_data;

# 按标签过滤查询
SELECT avg(value) FROM device_data
  WHERE workshop = '一车间'
  AND ts > now - 1d;

# 降采样查询（按小时聚合）
SELECT avg(value), max(value), min(value)
  FROM device_data
  WHERE ts > now - 7d
  INTERVAL(1h);

# 创建主题
CREATE TOPIC press_topic
  AS SELECT * FROM device_data
  WHERE device_type = '冲床';

# Python订阅示例
from taos import Consumer
consumer = Consumer.from_config(
  group_id='my_group',
  td_connect_ip='localhost'
)
consumer.subscribe(['press_topic'])
while True:
    msg = consumer.poll(1000)
    if msg:
        process(msg)
        consumer.commit()