DeleteMongo
概述
通过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条动物数据。
样例1:删除Query为{}
流程说明
按Query={}访问MongoDB执行删除
GenerateFlowFile设置自定义文本“{}”, 且DeleteMongo组件里只设置重要的连接信息。
删除效果是按照“删除模式”配置的值来删除。这里强调一下:默认是“删除一个”。也就是默认情况下,在执行成功后,删除的是满足条件的1个数据。如果想全量删除,可以改成"删除多个"。
样例2:删除Query为具体的条件
流程说明
按Query={name:"Rabbit"}访问MongoDB执行删除
GenerateFlowFile设置自定义文本为{name:"Rabbit", 且DeleteMongo组件里只设置重要的连接信息。 设置“什么也没有删除处理”为“标记成功”, 如果没有name为Rabbit的数据,则输出到成功线上。原来默认是走失败线。
注意:删除效果是按照“删除模式”配置的值来删除。强调:默认是“删除一个”。
执行结果
执行成功,路由到success线上。流文件内容为原来的流文件内容。
流程模板
参见附件(请右键另存保存):DeleteMongo示例