PutAzureCosmosDBRecord 2025.10.2.19¶
Pacote¶
org.apache.nifi | nifi-azure-nar
Descrição¶
Esse processador é um processador com reconhecimento de registros para inserir dados no Cosmos DB com a Core SQL API. Usa um Record Reader e esquema configurados para ler um conjunto de registros de entrada do corpo de um FlowFile e, em seguida, insere esses registros em um contêiner do Cosmos DB configurado.
Requisito de entrada¶
REQUIRED
Oferece suporte a propriedades dinâmicas confidenciais¶
falso
Propriedades¶
Propriedade |
Descrição |
|---|---|
Cosmos DB Access Key |
Chave de acesso do Cosmos DB do Portal do Azure (Configurações -> Chaves). Escolha uma chave de leitura e gravação para permitir a criação do banco de dados ou contêiner em tempo de execução |
Cosmos DB Conflict Handling Strategy |
Escolha se deseja ignorar ou executar upsert quando ocorrer um erro de conflito durante a inserção |
Cosmos DB Connection Service |
Se configurado, o serviço de controlador usado para obter a cadeia de caracteres de conexão e a chave de acesso |
Cosmos DB Consistency Level |
Escolha entre cinco níveis de consistência no espectro de consistência. Consulte a documentação do Cosmos DB para conhecer suas diferenças |
Cosmos DB Container ID |
O identificador exclusivo do contêiner |
Cosmos DB Name |
O nome ou ID do banco de dados. É usado como namespace para coleções ou contêineres de documentos |
Cosmos DB Partition Key |
A chave de partição usada para distribuir dados entre os servidores |
Cosmos DB URI |
URI do Cosmos DB, normalmente na forma de https://{databaseaccount}. documents.azure.com:443/ Observe que esse URL de host é para o Cosmos DB com a Core SQL API do Portal do Azure (Visão geral -> URI) |
Insert Batch Size |
O número de registros a serem agrupados para uma única operação de inserção no Cosmos DB |
Record Reader |
Especifica o Controller Service a ser usado para analisar os dados recebidos e determinar o esquema de dados |
Relações¶
Nome |
Descrição |
|---|---|
failure |
Todos os FlowFiles que não podem ser gravados no Cosmos DB são encaminhados para essa relação |
success |
Todos os FlowFiles que são gravados no Cosmos DB são roteados para essa relação |