更新时间:2022-06-27 GMT+08:00
分享

调试概述

  • 为什么管道任务没能输出期望的结果?
  • 管道任务中哪个算子环节出错了?
  • 算子处理后的数据结果是什么样的?

以上问题是我们在开发阶段经常遇到的问题。为了解决以上问题,我们提供了调试数据管道工具。用户可以上报测试数据对管道业务流程进行测试,用户可直观查看测试数据在每个算子输入和输出的内容。

工作原理:

启动测试模式后,输入类算子从数据源读取数据,将数据发送到下游的转化类算子,最终专递到输出类算子。调试工具会在每个算子的输入输出端监听数据流,最终将监听收集到的数据在页面进行展示。我们可以根据算子的输入输出数据定位以上我们所遇到的问题。

界面介绍

启动按钮

任务状态栏

输入输出

数据监控

操作指导

创建任务

启动测试任务

下载数据模板

修改数据模板

上传数据文本

查看测试结果

结束测试任务

数据模板

IoT设备接入数据源

API接入数据源

表1 算子支持表

算子类别

算子中文名称

算子英文名称

是否支持调试

是否展示输入数据

是否展示输出数据

输入类算子

IoT设备接入数据源

IoTDASource

是

否

是

API接入数据源

APISource

是

否

是

DIS数据源

DISSource

否

否

否

转化类算子

增加属性

AddProperties

是

是

是

数据计算

Calculate

是

是

是

删除属性

DeleteProperties

是

是

是

过滤算子

Filter

是

是

是

数据扁平

Flatten

是

是

是

产品过滤

ProductFilter

是

是

是

选择属性

SelectProperties

是

是

是

相邻消息计算

ContiguousCalculate

是

是

是

超时插补

TimeoutInterpolation

是

是

是

输出类算子

数据存储输出

DataStoreSink

是

是

否

DIS输出

DISSink

是

是

否

实时分析输出

RTASink

是

是

否

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

相关文档