流数据处理
流数据处理工具集用于在模型中接入、解析、过滤、转换并发送实时数据,帮助用户构建自动化流数据处理流程。
流数据处理通常从数据接收开始,通过要素解析将文本或消息内容转换为要素,再结合要素定义和转换器完成属性补充、坐标转换、字段计算、迭代和合并处理,最后通过发送器将结果写出到数据源或消息队列。
本章节按照流数据处理模型的构建脉络组织工具,包含接收器、要素解析、要素定义、发送器和转换器五类内容。用户可根据数据来源、数据格式、处理规则和输出目标选择相应工具,组合形成可发布和可计划执行的流数据处理模型。
SuperMap TransformX 2026 版本开始支持。
本章节将为您详细介绍以下内容:
- 接收器:用于获取流数据处理模型的输入数据。包括 文本接收器、Http接收器、简单RabbitMQ接收器、RabbitMQ接收器 和 RabbitMQ监听触发器。
- 要素解析:用于在 CSV、JSON、GeoJSON 文本和流数据要素之间进行解析或格式转换。包括 要素转CSV、要素转GeoJSON、要素转JSON、解析JSON要素、解析JSON要素集、解析CSV要素、解析GeoJson要素 和 解析GeoJson要素集。
- 要素定义:用于定义解析和处理过程中需要使用的属性、元数据、点数据描述和要素集名称。包括 添加属性、添加属性到要素集、获取属性值、定义元数据、定义点数据描述 和 修改要素集名称。
- 发送器:用于将处理后的要素、要素集或消息发送到目标位置。包括 写出数据集、批量写出数据集 和 RabbitMQ发送器。
- 转换器:用于对解析后的要素或要素集进行进一步加工处理。包括 字段计算、坐标转换器、迭代要素集 和 合并要素。