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 |
|---|---|
Clé d’accès Cosmos DB |
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 |
Stratégie de traitement des conflits de la DB Cosmos |
Choisir d’ignorer ou de réinsérer une erreur de conflit survenue lors de l’insertion |
Service de connexion de la DB Cosmos |
S’il est configuré, le Controller Service utilisé pour obtenir la chaîne de connexion et la clé d’accès |
Niveau de cohérence de la DB Cosmos |
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 |
ID du conteneur Cosmos DB |
L’identificateur unique du conteneur |
Nom de la DB Cosmos |
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 |
Clé de partition de la DB Cosmos |
La clé de partition utilisée pour répartir les données entre les serveurs |
URI de la DB Cosmos |
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) |
Insérer une taille de lot |
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 |