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.

Tags¶

azure, cosmos, insert, put, record

Requisito de entrada¶

REQUIRED

Oferece suporte a propriedades dinâmicas confidenciais¶

falso

Propriedades¶

Propriedade	Descrição
Chave de acesso do Cosmos DB	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
Estratégia de gestão de conflitos do Cosmos DB	Escolha se deseja ignorar ou executar upsert quando ocorrer um erro de conflito durante a inserção
Serviço de conexão do Cosmos DB	Se configurado, o serviço de controlador usado para obter a cadeia de caracteres de conexão e a chave de acesso
Nível de consistência do Cosmos DB	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
ID de contêiner do Cosmos DB	O identificador exclusivo do contêiner
Nome do Cosmos DB	O nome ou ID do banco de dados. É usado como namespace para coleções ou contêineres de documentos
Chave de partição do Cosmos DB	A chave de partição usada para distribuir dados entre os servidores
URI do Cosmos DB	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)
Tamanho do lote de inserção	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