Skip to main content

GetMongo

概述​

获取MongoDB的文档, 输出到数据流中。常见用法是将上级流文件内容做查询Query来查询，也支持通过组件设置"语句"来查询。

属性说明​

一般主要设置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条动物数据。

样例1：全量查询​

流程说明​

demo_all

GenerateFlowFile设置自定义文本“{}”, 且GetMongo组件里只设置重要的连接信息。

properties

执行结果​

success线上输出7个流文件，每个流文件内容和如下类似。是在mongodb中描述的各个内容。

{ "_id" : { "$oid" : "6371ffee56f1cd96c0c874f7" }, "name" : "Dog", "age" : 1 }

demo_all_result

样例2：条件查询(流文件内容做条件)​

流程说明​

流文件传入内容作为Query，可参考属性“语句”的描述。

demo_query

GenerateFlowFile设置自定义文本为{"name":"Peppa"}, 且GetMongo组件里只设置重要的连接信息。

执行结果​

success线上输出1个流文件，流文件内容：

{ "_id" : { "$oid" : "6371f79456f1cd96c0c874f6" }, "name" : "Peppa", "age" : 3 }

是在mongodb中满足条件name=Peppa查询出的内容。

流程模板​

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