更新时间: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

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

相关文档