调试概述
- 为什么管道任务没能输出期望的结果?
- 管道任务中哪个算子环节出错了?
- 算子处理后的数据结果是什么样的?
以上问题是我们在开发阶段经常遇到的问题。为了解决以上问题,我们提供了调试数据管道工具。用户可以上报测试数据对管道业务流程进行测试,用户可直观查看测试数据在每个算子输入和输出的内容。
工作原理:
启动测试模式后,输入类算子从数据源读取数据,将数据发送到下游的转化类算子,最终专递到输出类算子。调试工具会在每个算子的输入输出端监听数据流,最终将监听收集到的数据在页面进行展示。我们可以根据算子的输入输出数据定位以上我们所遇到的问题。
算子类别 |
算子中文名称 |
算子英文名称 |
是否支持调试 |
是否展示输入数据 |
是否展示输出数据 |
---|---|---|---|---|---|
输入类算子 |
IoT设备接入数据源 |
IoTDASource |
是 |
否 |
是 |
API接入数据源 |
APISource |
是 |
否 |
是 |
|
DIS数据源 |
DISSource |
否 |
否 |
否 |
|
转化类算子 |
增加属性 |
AddProperties |
是 |
是 |
是 |
数据计算 |
Calculate |
是 |
是 |
是 |
|
删除属性 |
DeleteProperties |
是 |
是 |
是 |
|
过滤算子 |
Filter |
是 |
是 |
是 |
|
数据扁平 |
Flatten |
是 |
是 |
是 |
|
产品过滤 |
ProductFilter |
是 |
是 |
是 |
|
选择属性 |
SelectProperties |
是 |
是 |
是 |
|
相邻消息计算 |
ContiguousCalculate |
是 |
是 |
是 |
|
超时插补 |
TimeoutInterpolation |
是 |
是 |
是 |
|
输出类算子 |
数据存储输出 |
DataStoreSink |
是 |
是 |
否 |
DIS输出 |
DISSink |
是 |
是 |
否 |
|
实时分析输出 |
RTASink |
是 |
是 |
否 |
输入类算子只记录输出数据,输出类算子只记录输入数据。