PutAzureCosmosDBRecord 2.3.0¶
BUNDLE¶
org.apache.nifi | nifi-azure-nar
DESCRIPTION¶
This processor is a record-aware processor for inserting data into Cosmos DB with Core SQL API. It uses a configured record reader and schema to read an incoming record set from the body of a Flowfile and then inserts those records into a configured Cosmos DB Container.
INPUT REQUIREMENT¶
REQUIRED
Supports Sensitive Dynamic Properties¶
false
PROPERTIES¶
Property |
Description |
|---|---|
azure-cosmos-db-conflict-handling-strategy |
Choose whether to ignore or upsert when conflict error occurs during insertion |
azure-cosmos-db-connection-service |
If configured, the controller service used to obtain the connection string and access key |
azure-cosmos-db-consistency-level |
Choose from five consistency levels on the consistency spectrum. Refer to Cosmos DB documentation for their differences |
azure-cosmos-db-container-id |
The unique identifier for the container |
azure-cosmos-db-key |
Cosmos DB Access Key from Azure Portal (Settings->Keys). Choose a read-write key to enable database or container creation at run time |
azure-cosmos-db-name |
The database name or id. This is used as the namespace for document collections or containers |
azure-cosmos-db-partition-key |
The partition key used to distribute data among servers |
azure-cosmos-db-uri |
Cosmos DB URI, typically in the form of https:/ (https:/)/{databaseaccount}.documents.azure.com:443/ Note this host URL is for Cosmos DB with Core SQL API from Azure Portal (Overview->URI) |
insert-batch-size |
The number of records to group together for one single insert operation against Cosmos DB |
record-reader |
Specifies the Controller Service to use for parsing incoming data and determining the data’s schema |
RELATIONSHIPS¶
NAME |
DESCRIPTION |
|---|---|
failure |
All FlowFiles that cannot be written to Cosmos DB are routed to this relationship |
success |
All FlowFiles that are written to Cosmos DB are routed to this relationship |