PutAzureCosmosDBRecord 2025.5.31.15¶
捆绑包¶
org.apache.nifi | nifi-azure-nar
描述¶
该处理器是记录感知处理器，用于通过 Core SQL API 将数据插入 Cosmos DB。它使用配置的记录读取器和架构从 Flowile 正文中读取传入记录集，然后将这些记录插入到配置的 DB 容器中。
输入要求¶
REQUIRED
支持敏感的动态属性¶
false
属性¶
属性 |
描述 |
|---|---|
azure-cosmos-db-conflict-handling-strategy |
选择在插入期间发生冲突错误时是忽略还是更新插入 |
azure-cosmos-db-connection-service |
如果已配置，则用于获取连接字符串和访问密钥的控制器服务 |
azure-cosmos-db-consistency-level |
从一致性光谱上的五个一致性级别中进行选择。有关它们的区别，请参阅 Cosmos DB 文档 |
azure-cosmos-db-container-id |
容器的唯一标识符 |
azure-cosmos-db-key |
来自 Azure 门户的 Cosmos DB 访问密钥（“设置”->“密钥”）。选择读写密钥以在运行时启用数据库或容器创建 |
azure-cosmos-db-name |
数据库名称或 ID。它用作文档集合或容器的命名空间 |
azure-cosmos-db-partition-key |
用于在服务器之间分配数据的分区键 |
azure-cosmos-db-uri |
Cosmos DB URI，通常采用以下格式：https:/ (https:/)/{databaseaccount}.documents.azure.com:443/。请注意，此主机 URL 适用于 Azure 门户中采用 Core SQL API 的 Cosmos DB（“概述”->“URI”） |
insert-batch-size |
对 Cosmos DB 进行一次插入操作时要分组的记录数量。 |
record-reader |
指定用于解析传入数据和确定数据架构的控制器服务 |
关系¶
名称 |
描述 |
|---|---|
failure |
无法写入 Cosmos DB 的所有 FlowFiles 都将路由到此关系 |
success |
写入 Cosmos DB 的所有 FlowFiles 都将路由到此关系 |