PutAzureCosmosDBRecord 2025.5.31.15

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.

Tags

azure, cosmos, insert, put, record

Requisito de entrada

REQUIRED

Oferece suporte a propriedades dinâmicas confidenciais

falso

Propriedades

Propriedade

Descrição

azure-cosmos-db-conflict-handling-strategy

Escolha se deseja ignorar ou executar upsert quando ocorrer um erro de conflito durante a inserção

azure-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

azure-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

azure-cosmos-db-container-id

O identificador exclusivo do contêiner

azure-cosmos-db-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

azure-cosmos-db-name

O nome ou ID do banco de dados. É usado como namespace para coleções ou contêineres de documentos

azure-cosmos-db-partition-key

A chave de partição usada para distribuir dados entre os servidores

azure-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