PutAzureCosmosDBRecord 2025.10.2.19¶

捆绑包¶

org.apache.nifi | nifi-azure-nar

描述¶

该处理器是记录感知处理器，用于通过 Core SQL API 将数据插入 Cosmos DB。它使用配置的记录读取器和架构从 Flowile 正文中读取传入记录集，然后将这些记录插入到配置的 DB 容器中。

标签¶

azure、cosmos、insert、put、record

输入要求¶

REQUIRED

支持敏感的动态属性¶

false

属性¶

属性	描述
Cosmos DB Access Key	来自 Azure 门户的 Cosmos DB 访问密钥（“设置”->“密钥”）。选择读写密钥以在运行时启用数据库或容器创建
Cosmos DB Conflict Handling Strategy	选择在插入期间发生冲突错误时是忽略还是更新插入
Cosmos DB Connection Service	如果已配置，则用于获取连接字符串和访问密钥的控制器服务
Cosmos DB Consistency Level	从一致性光谱上的五个一致性级别中进行选择。有关它们的区别，请参阅 Cosmos DB 文档
Cosmos DB Container ID	容器的唯一标识符
Cosmos DB Name	数据库名称或 ID。它用作文档集合或容器的命名空间
Cosmos DB Partition Key	用于在服务器之间分配数据的分区键
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 都将路由到此关系