把库表中的数据发送给MQTT
把库表中的数据发送给MQTT
所需积分:0
Restful API输入
调用API接口,可以获取返回数据体所在字段内容,把API返回的JSON数据标注为字段id放入全局变量中并作为流字段输出到下一节点中。
所需积分:0
多行合并为一行2.0
将输入的数据进行多行合并为一行输出
所需积分:0
多行合并为一行1.0
将输入的数据按行进行多行合并为一行输出
所需积分:0
查询ETL最新运行的流程
查询ETL最新运行的流程,可以把最新运行的流程信息汇总发送到邮件或其他地方进行统计监控
所需积分:0
执行Js脚本
用于编辑并执行js脚本的组件
所需积分:0
文件数据输入
文本文件读取数据并切分,将数据插入MySQL数据表中
所需积分:0
多列合并为一列
将输入的数据进行多列合并为一列输出
所需积分:0
执行Java脚本
用于编辑并执行java脚本的组件
所需积分:0
单列拆分为多行
将输入的数据按行进行单列拆分为多行输出
所需积分:0
执行SQL脚本
可以编写insert,update,delete,select语句后执行的组件
所需积分:0
Restful API输出
将流程中的数据输出到API中。
所需积分:0
单列拆分多列
将输入的数据按行进行单列拆分多列输出
所需积分:0
一行拆分为多行
将输入的数据按行进行拆分成多行数据输出
所需积分:0
HTML5报表数据发送
把数据转为HTML的表格并发送邮件
所需积分:0
字段名映射
根据上一节点的数据流,配置字段名映射并输出到库表中
所需积分:0
高级映射转换
根据Velocity语法将数据流的数据进行映射处理,再同步到数据库
所需积分:0
JSON转换器
将数据转换成json格式后再输出到后继节点
所需积分:0
调用JavaBean
用于调用自定义的JavaBean
所需积分:0
多行转换为多列
将输入的行数据转列数据输出
所需积分:0
数据清洗转换
对上一节点的数据进行判断,符合条件的记录将复制到后继节点中,不选择条件则表示全部满足,然后对其添加脱敏操作
所需积分:0
XML转JSON
将XML类型数据转换为JSON类型数据
所需积分:0
多列转换为多行
将输入的数据按行进行多列转换为多行输出
所需积分:0
kafka输入
获取调用接口的返回数据,推送到kafka消息队列中
所需积分:0
执行Java规则
用于编辑并执行Java规则
所需积分:0
API文件下载
用于通过API下载文件到选择目录。
所需积分:0
XML转JSON
将JSON类型数据转换为XML类型数据
所需积分:0
执行Python脚本
用于编辑并执行Python脚本
所需积分:0
用Java脚本节点读取指定表的字段信息
用Java脚本节点读取指定表的所有字段信息并传给后续节点使用
所需积分:0
JSON转XML
将JSON类型数据转换为XML类型数据
所需积分:0
移动或删除文件
通过移动或删除文件组件,将FTP文件下载组件下载到的文件移动到变量设置组件指定的位置
所需积分:0
数据加解密
将输入本节点数据整体(或指定部分字段数据)加密或解密输出,提供5种算法对数据进行加解密
所需积分:0
上游任务依赖SQL条件检测
上游任务运行完成后条件满足时可以立即运行后续任务
所需积分:0
字段值标注
给输出到表的数据流做标记,根据标记的类型对输出的数据做选择的操作
所需积分:0
FTP文件上传
上传符合要求的文件到FTP服务器中
所需积分:0
FTP文件下载
下载FTP服务器中符合要求的文件
所需积分:0
文件监听器
监听目录直到符合条件的文件出现
所需积分:0
字段值运算
可对上一节点的数据进行字段运算或者字段之间的字符串拼接,生成新的字段
所需积分:0
数据过滤器
将输入本节点的数据按设置条件过滤后出来输出到后继节点
所需积分:0
生成序列
为需要序号的字段生成序列数据
所需积分:0
文件压缩
从FTP服务器下载文件并进行压缩存储
所需积分:0