Skip to main content

PutMongo

概述​

将输入数据流的内容写入MongoDB

属性说明​

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

  • 连接URI 比如: mongodb://admin:passw0rd@172.19.124.23:27017/?compressors=disabled&gssapiServiceName=mongodb
  • 数据库名
  • 连接名：也就是Collection名

示例​

###样本数据 假设我们有admin库的myCollection有如下内容：（动物名和年龄，这里忽略描述格式）

name=Dog,age=1；name=Cat,age=1； name=Rabbit,age=2；
name=Peppa,age=3；name=Pig,age=1； name=Tigger,age=2； name=Long,age=3

共7条动物数据。

流程说明​

demo

GenerateFlowFile设置自定义文本{name:"Rabbit","age":2}, 且PutMongo组件里只设置重要的连接信息。

properties

执行结果​

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

此时，再去使用GetMongo组件查询时，设置条件为{name:"Rabbit"}, 输出到success线上2条数据。 因为原来就存在1条Rabbit数据。

流程模板​

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