PutAzureCosmosDBRecord

PutAzureCosmosDBRecord Processor

类型全限定名：cn.org.acal.lynxus.processors.azure.cosmos.document.PutAzureCosmosDBRecord

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

描述

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

属性

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

名称	默认值	可选值	描述
Cosmos DB Connection Service		控制器服务 API： `AzureCosmosDBConnectionService` cn.org.acal.lynxus-lynxus-azure-services-api-nar-2.11.8	如果配置，Controller Service用于获取连接字符串和访问密钥
Cosmos DB URI			Cosmos DB URI，通常格式为 https://{databaseaccount}.documents.azure.com:443/ 请注意，此主机 URL 用于来自 Azure 门户（概述->URI）的使用核心 SQL API 的 Cosmos DB 敏感属性：是
Cosmos DB Access Key			来自 Azure 门户（设置->密钥）的 Cosmos DB 访问密钥。选择读写密钥以在运行时启用数据库或容器创建敏感属性：是
Cosmos DB Consistency Level	`SESSION`	STRONG BOUNDED_STALENESS SESSION CONSISTENT_PREFIX EVENTUAL	从一致性谱系中选择五个一致性级别。请参阅 Cosmos DB 文档了解它们的区别
Cosmos DB Name			数据库名称或 ID。这用作文档集合或容器的Namespace
Cosmos DB Container ID			容器的唯一标识符
Cosmos DB Partition Key			用于在服务器之间分配数据的分区键
Record Reader		控制器服务 API： `RecordReaderFactory` cn.org.acal.lynxus-lynxus-standard-services-api-nar-2.11.8	指定用于解析传入数据并确定数据模式的 Controller Service
Insert Batch Size	`20`		针对 Cosmos DB 的一次插入操作分组在一起的记录数
Cosmos DB Conflict Handling Strategy	`IGNORE`	忽略 — 冲突的记录不会被插入，FlowFile也不会被路由失败更新插入 — 冲突的记录将被更新插入，并且FlowFile不会被路由到失败	选择在插入过程中发生冲突错误时是忽略还是更新插入

关系 (Relationships)

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

状态管理

该组件不存储状态。

受限 (Restricted)

该组件不受限。

输入要求

该组件要求有传入连接。

系统资源考量

资源	描述
MEMORY	An instance of this component can cause high usage of this system resource. Multiple instances or high concurrency settings may result a degradation of performance.