PutMongoRecord
描述:
通过配置记录读取器，将批量文档插入到MongoDB
标签:
mongodb, insert, record, put, 插入, 记录, 写入
参数:
如下列表中，必填参数则标识为加粗. 其他未加粗参数，则表示为可选参数。表中同时提到参数默认值设置, 并且 参数还支持 表达式语言.
| 名字 | 默认值 | 允许值列表 | 描述 |
|---|---|---|---|
| 连接 URI | MongoURI, 基本格式为： mongodb://host1[:port1],host2[:port2],...] 支持表达式语言 (仅支持变量) | ||
| 数据库名 | 用于连接的数据库名字 支持表达式语言 (支持流属性和变量) | ||
| 连接名 | 用于连接的名字 支持表达式语言 (支持流属性和变量) | ||
| SSL服务 | 控制器服务API: SSLContextService 实现: StandardRestrictedSSLContextService StandardSSLContextService | 用于提供客户端TLS/SSL安全认证连接信息的服务 | |
| 客户端认证 | 必须 | - 请求 - 必须 - 不需要 | 连接到安全（TLS/SSL）群集时的客户端身份验证策略。可能的值是REQUIRED, WANT, NONE。此属性仅在定义和启用了SSL服务时有效 |
| 写入关注 | ACKNOWLEDGED | - ACKNOWLEDGED - UNACKNOWLEDGED - FSYNCED - JOURNALED - REPLICA_ACKNOWLEDGED - MAJORITY | 决定写入MongoDB的关注策略 |
| 记录读取器 | 控制器服务API: RecordReaderFactory 实现: ParquetReader GrokReader SyslogReader Syslog5424Reader CSVReader AvroReader JsonPathReader JsonTreeReader ScriptedReader XMLReader | 指定用于解析输入数据流数据和数据schema的读取器服务 | |
| 插入批量大小 | 100 | 指定一次插入MongoDB操作的批量记录的数量 |
连线:
| 名字 | 描述 |
|---|---|
| success | 所有成功写入MongoDB的数据流将输出到该成功连线 |
| failure | 所有不能写入MongoDB的数据流将输出到该失败连线 |
读取属性:
未提供。
写入属性:
未提供。
状态管理:
该组件不保存状态。
限制:
该组件没有限制
输入流要求:
组件必须提供输入流。
系统资源考量:
未提供。