PutMongoRecord

PutMongoRecord Processor

类型全限定名：cn.org.acal.lynxus.processors.mongodb.PutMongoRecord

所属 Bundle：cn.org.acal.lynxus:lynxus-mongodb-nar:2.11.8

描述

此处理器是一个感知记录的处理器，用于将数据插入/更新到 MongoDB 中。它使用配置的记录读取器和架构从流文件主体读取传入记录集，然后将这些记录的批次插入/更新到配置的 MongoDB 集合中。

属性

下表中，加粗的属性为必填项；其余为可选项。表格同时标注默认值、是否支持表达式语言，以及是否为敏感属性（值会被加密）。

名称	默认值	可选值	描述
Client Service		控制器服务 API： `MongoDBClientService` cn.org.acal.lynxus-lynxus-mongodb-client-service-api-nar-2.11.8	如果配置，此属性将使用分配的客户端服务进行连接池。
Mongo Database Name			要使用的数据库的名称支持表达式语言：是（使用 FlowFile 属性与环境/系统变量求值）
Mongo Collection Name			要使用的集合的名称支持表达式语言：是（使用 FlowFile 属性与环境/系统变量求值）
Record Reader		控制器服务 API： `RecordReaderFactory` cn.org.acal.lynxus-lynxus-standard-services-api-nar-2.11.8	指定用于解析传入数据并确定数据模式的 Controller Service
Batch Size	`100`		针对 MongoDB 的一次插入/更新插入操作分组在一起的记录数。
Ordered	`False`	True False	执行有序或无序操作
Bypass Validation	`False`	True False	启用或禁用在插入或更新操作期间绕过文档 Schema 验证。绕过文档验证是 MongoDB 中的特权操作。启用此属性可能导致权限有限的用户出现授权错误。
Update Key Fields			基于此字段标识需要更新的文档的逗号分隔列表。如果设置了此属性，Lynxus 将尝试对所有文档执行 upsert 操作。如果未设置此属性，所有文档将被插入。
Update Mode	`one`	Update One — 仅更新与查询匹配的第一个文档。 Update Many — 更新与查询匹配的每个文档。使用 'mongodb.update.mode' FlowFile 属性。 — 使用传入 FlowFile 的 'mongodb.update.mode' 属性的值。可接受的值为 'one' 和 'many'。	选择更新单个文档或每个传入记录的多个文档。

关系 (Relationships)

名称	描述	自动终止
`failure`	所有无法写入 MongoDB 的 FlowFile 都会路由到此关系	否
`success`	所有写入 MongoDB 的 FlowFile 都会路由到此关系	否

读取的 FlowFile 属性

名称	描述
`mongodb.update.mode`	用于在每个 FlowFile 基础上控制更新模式的可配置参数。可接受的值为 'one' 和 'many'，控制单个传入记录是更新单个还是多个 Mongo 文档。

状态管理

该组件不存储状态。

受限 (Restricted)

该组件不受限。

输入要求

该组件要求有传入连接。