Skip to main content

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执行删除

demo_all

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

properties

删除效果是按照“删除模式”配置的值来删除。这里强调一下:默认是“删除一个”。也就是默认情况下,在执行成功后,删除的是满足条件的1个数据。如果想全量删除,可以改成"删除多个"。

样例2:删除Query为具体的条件

流程说明

按Query={name:"Rabbit"}访问MongoDB执行删除

demo_query

GenerateFlowFile设置自定义文本为{name:"Rabbit", 且DeleteMongo组件里只设置重要的连接信息。 设置“什么也没有删除处理”为“标记成功”, 如果没有name为Rabbit的数据,则输出到成功线上。原来默认是走失败线。

注意:删除效果是按照“删除模式”配置的值来删除。强调:默认是“删除一个”。

执行结果

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

demo_query

流程模板

参见附件(请右键另存保存):DeleteMongo示例