UpsertMilvus 2025.5.31.15¶
バンドル¶
com.snowflake.openflow.runtime | runtime-milvus-processors-nar
説明¶
指定されたコレクションのベクターをMilvusデータベースに挿入します。
入力要件¶
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に正常に送信されると、このリレーションシップにルーティングされます。 |