UpsertMilvus 2025.5.31.15

バンドル

com.snowflake.openflow.runtime | runtime-milvus-processors-nar

説明

指定されたコレクションのベクターをMilvusデータベースに挿入します。

タグ

chatbot, embeddings, gen ai, genai, generative ai, insert, llm, metadata, milvus, openflow, publish, text, upsert, vector

入力要件

REQUIRED

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

false

プロパティ

プロパティ

説明

コレクション名

使用するMilvusコレクション名

ID フィールド名

ベクターの IDs を保存するために使用する Milvus のフィールド名。フィールド名と共に記録パスが提供されない場合、 IDs は文字列形式のファイル名に基づいて生成されます。

ID 記録パス

記録内の ID フィールドへのパス。

最大バッチサイズ

FlowFile の記録数が大容量の場合、Milvus へのシングルリクエストの作成に NiFi のヒープを大量に消費する可能性があります。これを避けるために、Max Batch Sizeで1回のリクエストで送信する記録数を制限することができます。

メタデータフィールド名

ベクターに関連するその他のメタデータを格納するために使用するフィールドの名前。このデータは有効なJSON形式でなければなりません。

メタデータ記録パス

記録内のメタデータフィールドへのパス。

Milvus接続サービス

Milvusデータベースにアクセスする接続サービス

パーティション

操作を実行したいベクターデータベースのパーティション。データベースにパーティションが1つしかない場合は、空のままにします。

Record Reader

FlowFile の読み取りに使用するRecord Reader。

疎ベクトル フィールド名

疎ベクトルを格納するフィールドの名前。

疎ベクトル インデックス パス

疎ベクトルがプロバイダーとして提供される場合、この RecordPath は、使用する疎データのインデックスを指します。

疎ベクトル値パス

疎ベクトルがプロバイダーとして提供される場合、この RecordPath は、使用する疎データの値を指します。

テキストフィールド名

ベクターに関連するテキストを格納するために使用するMilvusのフィールド名。

テキスト記録パス

ベクターに関連付けられたテキストを含む記録内のフィールドへのパス。指定された場合、テキストはMilvusのテキストフィールドの下に挿入されます。指定がない場合、テキストはMilvusデータベースに送信されません。

ベクトルフィールド名

ベクトルの保存に使用するMilvusのフィールド名。

ベクトル記録パス

記録内のベクトルフィールドへのパス

リレーションシップ

名前

説明

failure

FlowFiles Milvusに送信できず、再試行が成功しないと予想される場合は、このリレーションシップにルーティングされます。

retry

FlowFiles Milvusへの送信に失敗し、再試行が有効な場合は、このリレーションにルーティングされます。

success

FlowFiles Milvusに正常に送信されると、このリレーションシップにルーティングされます。

こちらもご覧ください