PutAzureCosmosDBRecord 2025.10.2.19¶
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é.
Exigences en matière d’entrées¶
REQUIRED
Prend en charge les propriétés dynamiques sensibles¶
false
Propriétés¶
Propriété |
Description |
|---|---|
Cosmos DB Access 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 |
Cosmos DB Conflict Handling Strategy |
Choisir d’ignorer ou de réinsérer une erreur de conflit survenue lors de l’insertion |
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 |
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 |
Cosmos DB Container ID |
L’identificateur unique du conteneur |
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 |
Cosmos DB Partition Key |
La clé de partition utilisée pour répartir les données entre les serveurs |
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 |