PutAzureCosmosDBRecord 2025.10.2.19

バンドル

org.apache.nifi | nifi-azure-nar

説明

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

タグ

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

入力要件

REQUIRED

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

false

プロパティ

プロパティ

説明

コスモス DB アクセスキー

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

Cosmos DBの競合対応戦略

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

Cosmos DB接続サービス

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

Cosmos DBコンシステンシーレベル

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

Cosmos DBコンテナID

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

Cosmos DB名

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

Cosmos DBパーティションキー

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

Cosmos DB URI

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

バッチサイズの挿入

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

Record Reader

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

リレーションシップ

名前

説明

failure

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

success

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