PutEmail
PutEmail处理器单元主要功能是将FlowFile的内容以邮件的形式发送给配置的用户邮箱,也可以通过配置选择将FlowFile的内容以附件的方式发送出去。
PutFile
PutFile处理器主要功能是将FlowFile的内容以文件的形式写入本地磁盘。
上面的图中表示Processor将接收到的FlowFile的内容写入到本地的磁盘文件中。(注意:1.5.0之前此Processor不支持追加写入)
PutFTP
PutFTP处理器单元将FlowFile的内容拷贝到远程的FTP服务器上。
上面的图中表示Processor将输入的FlowFile的内容通过FTP协议写入到ftpServer01的/upload路径下且上传路径不存在的情况下自动创建路径。
PutSFTP
PutSFTP处理器单元主要功能将FlowFile的内容拷贝到远程的SFTP服务器上。
上面的图中表示Processor将输入的FlowFile的内容通过SFTP协议写入到sftpServer01的/upload路径下且上传路径不存在的情况下自动创建路径。
PutJMS
PutJMS处理器单元主要功能将FlowFile的内容座位JMS消息发送到JMS代理上,也可以通过配置根据FlowFile的属性来添加JMS配置属性。
PutSQL
PutSQL处理器单元的主要功能是将FlowFile的正文当作SQL DDL声明。FlowFile必须是正确的符合SQL规范的SQL声明。FlowFile的属性被用作DDL SQL的参数,这样可以有效的防止SQL注入攻击。
上面的图中表示Processor将输入的FlowFile的内容按照100个进行batch操作写入数据库。
PutKafka
PutKafka处理器单元专门是针对0.8.x版本的Kafka,它将FlowFile的内容以消息的形式发送到Kafka消息队列中。FlowFile的内容既可以作为一条完整的消息发送到Kafka,同时也可以通过分隔符将它切分为多个消息来发送到Kafka,例如换行符。
上面的图中表示Processor从localhost安装的Kafka的Sample_topic_A消费数据,并将数据输出到FlowFile的内容中。
PutMongo
PutMongo处理器单元将FlowFile的内容插入或者更新到MongoDB中。
上面的图中表示Processor根据输入的FlowFile内容中的doc来写入MongoDB。