PutAzureCosmosDBRecord 2025.5.31.15¶
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 |
|---|---|
azure-cosmos-db-conflict-handling-strategy |
Wählen Sie aus, ob bei einem Konfliktfehler während des Einfügens ignoriert oder aktualisiert werden soll. |
azure-cosmos-db-connection-service |
Falls konfiguriert, der Controller-Dienst, der verwendet wird, um die Verbindungszeichenfolge und den Zugriffsschlüssel zu erhalten |
azure-cosmos-db-consistency-level |
Wählen Sie aus fünf Konsistenzstufen auf dem Konsistenzspektrum. Die Unterschiede sind in der Cosmos-DB-Dokumentation beschrieben |
azure-cosmos-db-container-id |
Der eindeutige Bezeichner für den Container |
azure-cosmos-db-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 |
azure-cosmos-db-name |
Der Name oder die ID der Datenbank. Dies wird als Namespace für Dokumentensammlungen oder Container verwendet. |
azure-cosmos-db-partition-key |
Der Partitionsschlüssel, der für die Verteilung der Daten auf die Server verwendet wird |
azure-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. |