PutMongoRecord

描述:

该处理器是一种记录感知处理器,用于将数据插入MongoDB。它使用配置的记录读取器和架构从流文件的主体中读取传入的记录集,然后将这些记录的批次插入配置的MongoDB集合中。该处理器不支持更新,删除或更新。一次要插入的文档数由“插入批处理大小”(Insert Batch Size)配置属性控制。该值应设置为合理的大小,以确保MongoDB不会一次加载太多插入而过载。

标签:

mongodb,插入,记录,放置

特性:

在下面的列表中,必需属性的名称以粗体显示。其他任何属性(非粗体)均视为可选属性。该表还指示任何默认值,以及属性是否支持NiFi表达式语言

姓名默认值允许值描述
客户服务控制器服务API:
MongoDBClientService
实现: MongoDBControllerService
如果配置,此属性将使用分配的客户端服务进行连接池。
Mongo URI MongoURI,通常为以下形式:mongodb:// host1 [:port1] [,host2 [:port2],...]
支持表达式语言:true(仅使用变量注册表进行评估)
Mongo数据库名称要使用的数据库名称
支持表达式语言:true(将使用流文件属性和变量注册表进行评估)
Mongo集合名称要使用的集合的名称
支持表达式语言:true(将使用流文件属性和变量注册表进行评估)
SSL上下文服务控制器服务API:
SSLContextService
实现: StandardRestrictedSSLContextService
StandardSSLContextService
SSL上下文服务用于为TLS / SSL连接提供客户端证书信息。
客户端验证必需的
  • 必需的
  • 没有
连接到安全(TLS / SSL)群集时的客户端身份验证策略。可能的值是REQUIRED,WANT,NONE。仅当定义并启用了SSL上下文时,才使用此属性。
写关注已确认
  • 已确认
  • 未确认
  • 已同步
  • 日记
  • REPLICA_ACKNOWLEDGED
  • 多数
使用的写关注
记录读取器控制器服务API:
RecordReaderFactory
实现: JsonTreeReader
XMLReader
WindowsEventLogReader
SyslogReader
Syslog5424Reader
脚本阅读器
CSV阅读器
GrokReader
读者查询
JsonPathReader
AvroReader
实木复合地板阅读器
指定用于解析传入数据并确定数据模式的Controller Service
插入批次大小100针对MongoDB的一次插入操作将要分组在一起的记录数。

关系:

姓名描述
成功写入MongoDB的所有FlowFiles都将路由到此关系
失败所有无法写入MongoDB的FlowFiles都被路由到此关系

读取属性:

未指定。

写入属性:

未指定。

状态管理:

该组件不存储状态。

受限制的:

此组件不受限制。

输入要求:

该组件需要传入的关系。

系统资源注意事项:

未指定。