PutAzureCosmosDBRecord 2025.5.31.15¶

Bundle¶

org.apache.nifi | nifi-azure-nar

Description¶

Ce processeur est un processeur d’enregistrement pour l’insertion de données dans Cosmos DB avec Core SQL API. Il utilise un Record Reader et un schéma configurés pour lire un ensemble d’enregistrements entrants à partir du corps d’un FlowFile, puis insère ces enregistrements dans un conteneur Cosmos DB configuré.

Balises¶

azure, cosmos, insert, put, record

Exigences en matière d’entrées¶

REQUIRED

Prend en charge les propriétés dynamiques sensibles¶

false

Propriétés¶

Propriété	Description
azure-cosmos-db-conflict-handling-strategy	Choisir d’ignorer ou de réinsérer une erreur de conflit survenue lors de l’insertion
azure-cosmos-db-connection-service	S’il est configuré, le Controller Service utilisé pour obtenir la chaîne de connexion et la clé d’accès
azure-cosmos-db-consistency-level	Choisissez parmi cinq niveaux de cohérence sur le spectre de cohérence. Reportez-vous à la documentation de Cosmos DB pour connaître leurs différences
azure-cosmos-db-container-id	L’identificateur unique du conteneur
azure-cosmos-db-key	Clé d’accès Cosmos DB depuis le portail Azure (Paramètres->Clés). Choisissez une clé en lecture-écriture pour permettre la création d’une base de données ou d’un conteneur au moment de l’exécution
azure-cosmos-db-name	Le nom ou l’identifiant de la base de données. Il est utilisé comme espace de noms pour les collections de documents ou les conteneurs
azure-cosmos-db-partition-key	La clé de partition utilisée pour répartir les données entre les serveurs
azure-cosmos-db-uri	URI DB Cosmos, généralement sous la forme de https://{databaseaccount}. documents.azure.com:443/ Notez que cet hôte URL est pour Cosmos DB avec API SQL Core à partir d’Azure Portal (Aperçu->URI)
insert-batch-size	Le nombre d’enregistrements à regrouper pour une seule opération d’insertion dans Cosmos DB
record-reader	Spécifie le Controller Service à utiliser pour analyser les données entrantes et déterminer le schéma des données

Relations¶

Nom	Description
failure	Tous les FlowFiles qui ne peuvent pas être écrits sur Cosmos DB sont routés vers cette relation
success	Tous les FlowFiles qui sont écrits dans Cosmos DB sont routés vers cette relation