数据订阅
TDengine 3.0.0.0 开始对消息队列做了大幅的优化和增强以简化用户的解决方案。
创建 topic
TDengine 创建 topic 的个数上限通过参数 tmqMaxTopicNum 控制，默认 20 个。
TDengine 使用 SQL 创建一个 topic，共有三种类型的 topic：
查询 topic
语法：
CREATE TOPIC [IF NOT EXISTS] topic_name as subquery
通过 SELECT 语句订阅（包括 SELECT *，或 SELECT ts, c1 等指定查询订阅，可以带条件过滤、标量函数计算，但不支持聚合函数、不支持时间窗口聚合）。需要注意的是：
- 该类型 TOPIC 一旦创建则订阅数据的结构确定。
- 被订阅或用于计算的列或标签不可被删除（
ALTER table DROP）、修改（ALTER table MODIFY）。 - 若发生表结构变更，新增的列不出现在结果中。
- 对于 select *，则订阅展开为创建时所有的列（子表、普通表为数据列，超级表为数据列加标签列）
超级表 topic
语法：
CREATE TOPIC [IF NOT EXISTS] topic_name [with meta] AS STABLE stb_name [where_condition]
与 SELECT * from stbName 订阅的区别是：
- 不会限制用户的表结构变更。
- 返回的是非结构化的数据：返回数据的结构会随之超级表的表结构变化而变化。
- with meta 参数可选，选择时将返回创建超级表，子表等语句，主要用于taosx做超级表迁移
- where_condition 参数可选，选择时将用 来过滤符合条件的子表，订阅这些子表。where 条件里不能有普通列，只能是tag或tbname，where条件里可以用函数，用来过滤tag，但是不能是聚合函数，因为子表tag值无法做聚合。也可以是常量表达式，比如 2 > 1（订阅全部子表），或者 false（订阅0个子表）
- 返回数据不包含标签。
数据库 topic
语法：
CREATE TOPIC [IF NOT EXISTS] topic_name [with meta] AS DATABASE db_name;
通过该语句可创建一个包含数据库所有表数据的订阅
- with meta 参数可选，选择时将返回创建数据库里所有超级表，子表的语句，主要用于taosx做数据库迁移
说明： 超级表订阅和库订阅属于高级订阅模式，容易出错，如确实要使用，请咨询专业人员。
删除 topic
如果不再需要订阅数据，可以删除 topic，需要注意：只有当前未在订阅中的 TOPIC 才能被删除。
/* 删除 topic */
DROP TOPIC [IF EXISTS] topic_name;
此时如果该订阅主题上存在 consumer，则此 consumer 会收到一个错误。
查看 topic
SHOW TOPICS;
显示当前数据库下的所有主题的信息。
创建消费组
消费组的创建只能通过 TDengine 客户端驱动或者连接器所提供的 API 创建。
删除消费组
DROP CONSUMER GROUP [IF EXISTS] cgroup_name ON topic_name;
删除主题 topic_name 上的消费组 cgroup_name。
查看消费组
SHOW CONSUMERS;
显示当前数据库下所有活跃的消费者的信息。
查看订阅信息
SHOW SUBSCRIPTIONS;
显示 consumer 与 vgroup 之间的分配关系和消费信息
