PutRethinkDB
描述:
将输入数据流的JSON文档写入到RethinkDB (https://www.rethinkdb.com/). 输入数据流应该包含JSON对象或JSON数组
标签:
rethinkdb, stream, insert, update, write, put, 插入, 更新, 写入, 输出
参数:
如下列表中，必填参数则标识为加粗. 其他未加粗参数，则表示为可选参数。表中同时提到参数默认值设置, 参数还支持 表达式语言, 并且 如果将一个参数认定为"敏感", 表示是加密状态. 在输入一个敏感参数时, 确保 orchsym.properties 文件中存在属性设置 orchsym.sensitive.props.key.
| 名字 | 默认值 | 允许值列表 | 描述 |
|---|---|---|---|
| 数据库名 | 连接RethinkDB数据库的名字 | ||
| 主机 | localhost | 指定RethinkDB主机名 | |
| 端口 | 28015 | 指定连接RethinkDB数据库的端口 | |
| 用户名 | 指定用于访问RethinkDB数据库的用户名 | ||
| 密码 | 指定用于访问RethinkDB数据库的用户密码 敏感状态 | ||
| 表名 | 指定连接RethinkDB数据库的表名 | ||
| 字符编码 | UTF-8 | 指定文档数据的字符编码 支持表达式语言 (支持流属性和变量) | |
| 冲突策略 | 更新 | - 更新  - 替换 - 错误 | 指定插入已存在文档时使用的冲突策略选择 支持表达式语言 (支持流属性和变量) |
| 文档持久化策略 | 硬持久化 | - 硬持久化 - 软持久化 | 指定文档修改的持久化策略 支持表达式语言 (支持流属性和变量) |
| 最大文档数 | 1 MB | 允许在一批中发送的最大文档数 |
连线:
| 名字 | 描述 |
|---|---|
| success | 成功处理的数据输出到此连线 |
| failure | 处理数据失败时，路由到此连线 |
读取属性:
未提供。
写入属性:
| 名字 | 描述 |
|---|---|
| rethinkdb.error.message | RethinkDB错误消息 |
| rethinkdb.insert.errors | 插入文档时的错误计数 |
| rethinkdb.insert.deleted | 删除的文档数 |
| rethinkdb.insert.generated_keys | 插入文档时生成的键 |
| rethinkdb.insert.inserted | 插入的文档数 |
| rethinkdb.insert.replaced | 替换的文档数 |
| rethinkdb.insert.skipped | 由于已存在而跳过的文档数 |
| rethinkdb.insert.unchanged | 由于已存在而未修改的文档数 |
| rethinkdb.insert.first_error | 插入文档的第一个错误 |
| rethinkdb.insert.warnings | 插入时返回大量ID时的警告消息 |
状态管理:
该组件不保存状态。
限制:
该组件没有限制
输入流要求:
组件必须提供输入流。
系统资源考量:
未提供。