PutAzureCosmosDBRecord 2025.10.2.19¶
Bundle¶
org.apache.nifi | nifi-azure-nar
Beschreibung¶
Dieser Prozessor ist ein datensatzbasierter Prozessor zum Einfügen von Daten in eine Cosmos-DB mit der Core SQL-API. Es verwendet einen konfigurierten Datensatzleser und ein Schema, um eine eingehende Datensatzgruppe aus dem Body eines FlowFile zu lesen, und fügt diese Datensätze dann in einen konfigurierten Cosmos DB-Container ein.
Eingabeanforderung¶
REQUIRED
Unterstützt sensible dynamische Eigenschaften¶
false
Eigenschaften¶
Eigenschaft |
Beschreibung |
|---|---|
Cosmos DB Access Key |
Cosmos DB-Zugriffsschlüssel aus dem Azure-Portal (Einstellungen->Schlüssel). Wählen Sie einen Lese-Schreib-Schlüssel, um die Erstellung von Datenbanken oder Containern während der Laufzeit zu ermöglichen |
Cosmos DB Conflict Handling Strategy |
Wählen Sie aus, ob bei einem Konfliktfehler während des Einfügens ignoriert oder aktualisiert werden soll. |
Cosmos DB Connection Service |
Falls konfiguriert, der Controller-Dienst, der verwendet wird, um die Verbindungszeichenfolge und den Zugriffsschlüssel zu erhalten |
Cosmos DB Consistency Level |
Wählen Sie aus fünf Konsistenzstufen auf dem Konsistenzspektrum. Die Unterschiede sind in der Cosmos-DB-Dokumentation beschrieben |
Cosmos DB Container ID |
Der eindeutige Bezeichner für den Container |
Cosmos DB Name |
Der Name oder die ID der Datenbank. Dies wird als Namespace für Dokumentensammlungen oder Container verwendet. |
Cosmos DB Partition Key |
Der Partitionsschlüssel, der für die Verteilung der Daten auf die Server verwendet wird |
Cosmos DB URI |
Die URI der Cosmos-DB, typischerweise in der Form https://{databaseaccount}. documents.azure.com:443/ Beachten Sie, dass diese Host-URL für die Cosmos DB mit Core SQL API aus dem Azure Portal (Übersicht->URI) ist |
Insert Batch Size |
Die Anzahl der Datensätze, die für eine einzelne Einfügeoperation in der Cosmos-DB zusammengefasst werden sollen. |
Record Reader |
Gibt den Controller Service an, der für das Parsen eingehender Daten und die Bestimmung des Datenschemas verwendet werden soll |
Beziehungen¶
Name |
Beschreibung |
|---|---|
failure |
Alle FlowFiles, die nicht in die Cosmos-DB geschrieben werden können, werden an diese Beziehung weitergeleitet. |
success |
Alle FlowFiles, die in die Cosmos-DB geschrieben werden, werden an diese Beziehung weitergeleitet. |