メインコンテンツまでスキップ

flush()

この操作は、segment を手動でシールし、データをディスクに永続化します。すべてのデータが collection に挿入された後にこの操作を呼び出すことを推奨します。

javascript
await milvusClient.flush(data)
📘注意

Milvus は一定間隔でデータを自動的に永続ストレージへ flush します。この自動データ永続化メカニズムに依存することを推奨します。

Request Syntax​

javascript
await milvusClient.flush({
    db_name?: string,
    collection_names: string[],
    timeout?: number
})

PARAMETERS:

  • db_name (string) -

    対象の collection が属する対象データベースの名前。

  • collection_names (string[]) -

    [REQUIRED]

    対象 collection 名のリスト。

  • timeout (number)

    この操作のタイムアウト時間。

    これを None に設定すると、いずれかのレスポンスが到着するか、何らかのエラーが発生した時点でこの操作はタイムアウトします。

RETURNS Promise<FlushResult>

このメソッドは FlushResult オブジェクトに解決される promise を返します。

typescript
{
    coll_segIDs: Record<string, { data: number[] }>,
    status:  ResStatus
}

PARAMETERS:

  • coll_segIDs (Record<string, { data: number[] }>) -
    collection 名から、この flush によってシールされた segment ID へのマッピングです。永続化を確認するには、返された ID を getFlushState() とともに使用します。

  • ResStatus
    ResStatus オブジェクト。

    • code (number) -

      操作結果を示すコードです。この操作が成功した場合は 0 のままです。

    • error_code (string | number) -

      発生したエラーを示すエラーコードです。この操作が成功した場合は Success のままです。

    • reason (string) -

      報告されたエラーの理由を示す文字列です。この操作が成功した場合は空文字列のままです。

Example​

java
const milvusClient = new MilvusClient({
    address: 'YOUR_CLUSTER_ENDPOINT',
    token: 'YOUR_CLUSTER_TOKEN',
});
const flushStatus = await milvusClient.flush({
    collection_names: ['my_collection'],
});
Ctrl I