Apache Nifi

  • Post author:
  • Post category:其他


2.3.7数据发送类处理器单元

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。



版权声明:本文为wangmin1983原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。