Skip to main content

PutMongoRecord

概述​

通过配置记录读取器，将批量文档插入到MongoDB。支持多种格式Record数据：CSV JSON Avro Xml

属性说明​

一般主要设置mongodb连接信息和查询的Collection名，其他属性可根据实际情况配置(查阅描述)。

  • 连接URI 比如: mongodb://admin:passw0rd@172.19.124.23:27017/?compressors=disabled&gssapiServiceName=mongodb
  • 数据库名
  • 连接名：也就是Collection名
  • 记录读取器: 按照要处理的Record数据格式来配置。

示例​

###样本数据 GenerateFlowFile设置自定义文本如下, 比如, 这里是CSV数据。

name, age
Dog, 1
Cat, 1
Rabbit, 2
Peppa, 3
Pig, 1
Tigger, 2
Long, 3
流程说明​

将样例的CSV数据，批量插入到MongoDB数据库。

demo

设置重要的连接信息, 在设置具体CSV数据的Reader。

properties

样例数据带CSV数据表头，这里设置"首行作为头部"为是。 reader_properties

执行结果​

执行成功，路由到success线上。流文件内容为原来的流文件内容。

此时，再去使用GetMongo组件查询时，可以将输出全部查询出来。

流程模板​

参见附件(请右键另存保存)：PutMongoRecord示例