流式计算

# 流式计算组件

RuleGo 提供了基于 StreamSQL 引擎的流式计算组件，支持使用SQL语法进行实时数据处理。

# 组件列表

# streamTransform

节点类型： x/streamTransform

流转换器组件，用于处理非聚合的SQL查询，支持：

数据过滤和字段选择
字段重命名和计算
条件过滤和数据验证
单条和批量数据处理
60+内置函数支持

适用场景： 实时数据清洗、格式转换、简单计算

# streamAggregator

节点类型： x/streamAggregator

流聚合器组件，用于处理聚合SQL查询，支持：

窗口聚合（滚动窗口、滑动窗口、计数窗口等）
分组聚合和多维度统计
聚合函数（COUNT、SUM、AVG、MAX、MIN灯）
实时计算和结果输出

适用场景： 实时统计分析、监控报警、数据汇总

# 快速开始

# 1. 安装依赖

go get github.com/rulego/rulego-components

# 2. 注册组件

import _ "github.com/rulego/rulego-components/stats/streamsql"

1
2

# 3. 使用示例

# 数据转换示例

{
  "id": "transform1",
  "type": "x/streamTransform",
  "name": "温度转换",
  "configuration": {
    "sql": "SELECT deviceId, temperature, temperature * 1.8 + 32 as temp_fahrenheit FROM stream WHERE temperature > 0"
  }
}

1
2
3
4
5
6
7
8

# 数据聚合示例

{
  "id": "aggregator1",
  "type": "x/streamAggregator",
  "name": "温度统计",
  "configuration": {
    "sql": "SELECT deviceId, AVG(temperature) as avg_temp, COUNT(*) as count FROM stream GROUP BY deviceId, TumblingWindow('5m')"
  }
}

1
2
3
4
5
6
7
8

# 应用场景

# IoT数据处理

传感器数据清洗和格式化
实时温度、湿度等指标监控
设备状态统计和报警

# 实时监控

系统性能指标聚合
异常检测和告警
实时仪表板数据处理

# 数据分析

流式数据预处理
实时统计计算
多维度数据分析

在 GitHub 上编辑此页

上次更新: 2025/07/27, 15:17:27

← Modbus Node 流聚合器→