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

flushAllSync()

この操作はすべての collection を flush し、flush 操作が完了するまで待機します。内部的には flushAll を呼び出し、その後 flush が完了するまで getFlushAllState をポーリングします。

typescript
await milvusClient.flushAllSync(data?: FlushAllReq)

リクエスト構文​

typescript
await milvusClient.flushAllSync({
    db_name?: string,
    timeout?: number,
    client_request_id?: string,
})

パラメーター:

  • db_name (string) -
    データベース名です。省略可能です。

  • timeout (number) -
    RPC に許可される時間の長さをミリ秒単位で指定する省略可能な値です。undefined に設定されている場合、クライアントはサーバーが応答するかエラーが発生するまで待機し続けます。デフォルトは undefined です。

  • client_request_id (string) -
    リクエスト追跡用のトレース ID です。省略可能です。

戻り値 Promise<GetFlushAllStateResponse>

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

typescript
{
    flushed: boolean,
    status:  ResStatus
}

パラメーター:

  • flushed (boolean) -
    flush-all 操作が完全に完了したかどうかを示します。flushAllSync() は完了までブロックするため、成功時にはこの値は true です。

  • ResStatus
    ResStatus オブジェクトです。

    • code (number) -

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

    • error_code (string | number) -

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

    • reason (string) -

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

例​

javascript
import { MilvusClient } from '@zilliz/milvus2-sdk-node';

const client = new MilvusClient({
    address: 'YOUR_CLUSTER_ENDPOINT',
    token: 'YOUR_CLUSTER_TOKEN',
});

const res = await client.flushAllSync();
Ctrl I