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