PutAzureCosmosDBRecord 2025.5.31.15

バンドル

org.apache.nifi | nifi-azure-nar

説明

このプロセッサーは、Core SQL API でCosmos DB にデータを挿入するための記録認識プロセッサーです。構成されたRecord Readerとスキーマを使用して、Flowfileの本文から受信記録セットを読み取り、それらの記録を構成されたCosmos DB コンテナーに挿入します。

タグ

Azure、cosmos、インサート、プット、記録

入力要件

REQUIRED

機密動的プロパティをサポート

false

プロパティ

プロパティ

説明

azure-cosmos-db-conflict-handling-strategy

挿入時に競合エラーが発生した場合、無視するかアップサートを行うかを選択します。

azure-cosmos-db-connection-service

構成されている場合、接続文字列とアクセスキーの取得に使用されるController Service。

azure-cosmos-db-consistency-level

コンシステンシー・スペクトル上の5つのコンシステンシー・レベルからお選びください。それぞれの違いについては、Cosmos DB のドキュメントを参照してください。

azure-cosmos-db-container-id

コンテナー固有の識別子。

azure-cosmos-db-key

AzureポータルからCosmos DB アクセスキー(Settings->Keys)。実行時にデータベースまたはコンテナーの作成を有効にするために、読み取り/書き込みキーを選択します。

azure-cosmos-db-name

データベース名または ID。ドキュメントコレクションやコンテナーの名前空間として使用されます。

azure-cosmos-db-partition-key

サーバー間のデータ分散に使用されるパーティション・キー

azure-cosmos-db-uri

Cosmos DB URI、通常は https://{databaseaccount}.documents.azure.com:443/ このホスト URL は Cosmos 用 DB と Azure ポータルからの Core SQL API (概要->URI)。

insert-batch-size

Cosmos DB に対する1回の挿入操作でグループ化する記録数

record-reader

受信データのパースとスキーマの決定に使用する Controller Service を指定します。

リレーションシップ

名前

説明

failure

Cosmos DB に書き込めないすべての FlowFiles は、このリレーションシップにルーティングされます。

success

Cosmos DB に書き込まれるすべての FlowFiles は、このリレーションシップにルーティングされます。