RuleGo RuleGo
🏠首页
  • 快速入门
  • 规则链
  • 标准组件
  • 扩展组件
  • 自定义组件
  • 可视化
  • RuleGo-Server
  • AOP
  • 触发器
  • 高级主题
  • 性能
  • 标准组件
  • 扩展组件
  • 自定义组件
  • 流式计算
  • 组件市场
  • 概述
  • 快速入门
  • 路由
  • DSL
  • API
  • Options
  • 组件
🔥编辑器 (opens new window)
  • 可视化编辑器 (opens new window)
  • RuleGo-Server (opens new window)
  • 🌊StreamSQL
  • 🤖智能体框架
  • 🦀TPCLAW 智能体平台 (opens new window)
  • ❓问答

    • FAQ
💖支持
👥加入社区
  • Github (opens new window)
  • Gitee (opens new window)
  • GitCode (opens new window)
  • 更新日志 (opens new window)
  • English
  • 简体中文
🏠首页
  • 快速入门
  • 规则链
  • 标准组件
  • 扩展组件
  • 自定义组件
  • 可视化
  • RuleGo-Server
  • AOP
  • 触发器
  • 高级主题
  • 性能
  • 标准组件
  • 扩展组件
  • 自定义组件
  • 流式计算
  • 组件市场
  • 概述
  • 快速入门
  • 路由
  • DSL
  • API
  • Options
  • 组件
🔥编辑器 (opens new window)
  • 可视化编辑器 (opens new window)
  • RuleGo-Server (opens new window)
  • 🌊StreamSQL
  • 🤖智能体框架
  • 🦀TPCLAW 智能体平台 (opens new window)
  • ❓问答

    • FAQ
💖支持
👥加入社区
  • Github (opens new window)
  • Gitee (opens new window)
  • GitCode (opens new window)
  • 更新日志 (opens new window)
  • English
  • 简体中文

广告采用随机轮播方式显示 ❤️成为赞助商
  • 快速入门

  • 规则链

  • 标准组件

  • 扩展组件

    • 扩展组件概述
    • 过滤器

    • 动作

    • 转换器

    • 外部的

    • ai

    • CI

    • IoT

      • IoT 组件概览
      • 输入端点

      • 协议采集

      • 时序数据库

        • 时序数据库写
        • 时序数据库查
          • 配置
          • 支持的 driver
          • 输出格式(msg.Data)
        • InfluxDB 写
        • InfluxDB 查
        • TDengine 写
        • TDengine 查
        • TimescaleDB 写
        • TimescaleDB 查
        • Prometheus Remote Write
      • 控制

      • IoT 场景示例
    • 流式计算

    • 服务发现

    • 文件

  • 自定义组件

  • 组件市场

  • 可视化

  • AOP

  • 触发器

  • 高级主题

  • 智能体框架

  • RuleGo-Server

  • 问题

目录

时序数据库查

x/tsdbQuery组件:v0.37.0+通用时序数据库查询节点,按 driver 配置委派到具体 TSDB 后端。

需要额外引入扩展库: rulego-components-iot (opens new window)

# 配置

字段 类型 说明 默认值
driver string TSDB 驱动:opengemini/influxdb/tdengine/timescaledb 必填
(其余字段) — 透传给对应 TSDB 查询节点(连接与查询语句字段,见下表) —

# 支持的 driver

driver 委派节点 查询语言 连接配置 查询语句字段
opengemini x/opengeminiQuery SQL server/username/password/database command
influxdb x/influxdbQuery Flux url/token/org/bucket query
tdengine x/tdengineQuery SQL dsn (REST: root:taosdata@http(host:6041)/) /db query
timescaledb x/timescaledbQuery SQL (PostgreSQL) dsn/db query

promremote 为只写后端,不支持查询。各库连接配置与对应写节点一致,见 x/tsdbWrite。

# 输出格式(msg.Data)

各 driver 的查询结果统一为列+行的 QueryResult JSON,路由到 Success;查询出错路由到 Failure:

{
  "Columns": ["time", "device_id", "temp"],
  "Rows": [
    {"time": "2026-07-29T10:00:00Z", "device_id": "d1", "temp": 25.3}
  ]
}
1
2
3
4
5
6

列名与各后端的原生方言一致(如 InfluxDB Flux 返回 _time/_value/_field 等内置列)。查询语句按所选后端原生语言编写,支持 ${msg.xx}/${metadata.xx} 模板。

在 GitHub 上编辑此页 (opens new window)
上次更新: 2026/07/29, 08:03:51
时序数据库写
InfluxDB 写

← 时序数据库写 InfluxDB 写→

Theme by Vdoing | Copyright © 2023-2026 RuleGo Team | Apache 2.0 License

  • 跟随系统
  • 浅色模式
  • 深色模式
  • 阅读模式