调试概述
- 为什么管道任务没能输出期望的结果?
- 管道任务中哪个算子环节出错了?
- 算子处理后的数据结果是什么样的?
以上问题是我们在开发阶段经常遇到的问题。为了解决以上问题,我们提供了调试数据管道工具。用户可以上报测试数据对管道业务流程进行测试,用户可直观查看测试数据在每个算子输入和输出的内容。
工作原理:
启动测试模式后,输入类算子从数据源读取数据,将数据发送到下游的转化类算子,最终专递到输出类算子。调试工具会在每个算子的输入输出端监听数据流,最终将监听收集到的数据在页面进行展示。我们可以根据算子的输入输出数据定位以上我们所遇到的问题。

算子类别 | 算子中文名称 | 算子英文名称 | 是否支持调试 | 是否展示输入数据 | 是否展示输出数据 |
|---|---|---|---|---|---|
输入类算子 | IoT设备接入数据源 | IoTDASource | 是 | 否 | 是 |
API接入数据源 | APISource | 是 | 否 | 是 | |
DIS数据源 | DISSource | 否 | 否 | 否 | |
转化类算子 | 增加属性 | AddProperties | 是 | 是 | 是 |
数据计算 | Calculate | 是 | 是 | 是 | |
删除属性 | DeleteProperties | 是 | 是 | 是 | |
过滤算子 | Filter | 是 | 是 | 是 | |
数据扁平 | Flatten | 是 | 是 | 是 | |
产品过滤 | ProductFilter | 是 | 是 | 是 | |
选择属性 | SelectProperties | 是 | 是 | 是 | |
相邻消息计算 | ContiguousCalculate | 是 | 是 | 是 | |
超时插补 | TimeoutInterpolation | 是 | 是 | 是 | |
输出类算子 | 数据存储输出 | DataStoreSink | 是 | 是 | 否 |
DIS输出 | DISSink | 是 | 是 | 否 | |
实时分析输出 | RTASink | 是 | 是 | 否 |

输入类算子只记录输出数据,输出类算子只记录输入数据。

