# StreamSQL 非聚合场景使用示例 本示例展示了StreamSQL在非聚合场景中的各种应用,包括实时数据转换、过滤、清洗等功能。 ## 运行示例 ```bash cd examples/non-aggregation go run main.go ``` ## 场景说明 ### 1. 实时数据清洗和标准化 **场景描述**: 对输入的脏数据进行清洗和标准化处理,包括: - 空值处理(COALESCE) - 字符串规范化(UPPER, TRIM) - 数值精度处理(ROUND) - 状态码转换(CASE WHEN) - 无效数据过滤(WHERE条件) **适用场景**: - IoT设备数据清洗 - 日志标准化处理 - 数据质量保证 ### 2. 数据富化和计算字段 **场景描述**: 基于原始数据计算和添加新字段,包括: - 单位转换(摄氏度转华氏度) - 分类标签生成(温度分级) - 字符串拼接(全标识符) - 时间戳添加 - 比率计算 **适用场景**: - 数据预处理 - 业务规则应用 - 指标计算 ### 3. 实时告警和事件过滤 **场景描述**: 实时检测异常数据并生成告警事件,包括: - 阈值检测 - 告警级别分类 - 告警消息生成 - 时间戳记录 **适用场景**: - 监控系统 - 异常检测 - 实时告警 ### 4. 数据格式转换 **场景描述**: 将数据转换为不同的格式,包括: - JSON格式输出 - CSV格式输出 - 自定义格式转换 **适用场景**: - 数据接口适配 - 多系统集成 - 数据导出 ### 5. 基于条件的数据路由 **场景描述**: 根据数据内容决定数据的路由目标,包括: - 条件路由规则 - 优先级分类 - 主题分发 **适用场景**: - 消息队列路由 - 数据分发 - 负载均衡 ### 6. 嵌套字段处理 **场景描述**: 处理复杂的嵌套JSON数据,包括: - 深层字段提取 - 嵌套字段组合 - 条件判断 **适用场景**: - JSON数据处理 - 复杂数据结构解析 - API数据转换 ## 核心特性 ### 实时处理 - 每条数据立即处理,无需等待窗口 - 超低延迟,适合实时场景 - 支持高吞吐量数据流 ### 丰富的函数支持 - 字符串处理:UPPER, LOWER, TRIM, CONCAT, SUBSTRING等 - 数学计算:ROUND, CAST, 算术运算等 - 条件判断:CASE WHEN, COALESCE, IF等 - 时间函数:NOW, DATE_FORMAT等 - 类型转换:CAST, TO_JSON等 ### 灵活的字段操作 - 字段选择和别名 - 嵌套字段访问(点号语法) - 计算字段生成 - 表达式计算 ### 强大的过滤能力 - WHERE条件过滤 - 复杂表达式支持 - 多条件组合(AND, OR) - 模式匹配(LIKE 语法) ## 性能特点 - **低延迟**: 每条数据立即处理输出 - **高吞吐**: 支持高频数据流 - **内存友好**: 无需缓存数据,即时处理 - **CPU高效**: 简单的数据转换操作