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

flushAll()

この操作はすべての collection を flush し、すべての segment を sealed にして、データをディスクに永続化します。

typescript
await milvusClient.flushAll(data?: FlushAllReq)

リクエスト構文​

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

パラメータ:

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

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

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

戻り値 Promise<FlushAllResponse>

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

typescript
{
flush_all_ts: number,
flush_all_tss: Record<string, number>,
flush_all_msgs: Record<string, any>,
cluster_info: FlushClusterInfo,
status: ResStatus
}

パラメータ:

  • flush_all_ts (number) -
    flush を識別する単一の hybrid timestamp です。非推奨です。マルチ cluster デプロイでは flush_all_tss を使用してください。

  • flush_all_tss (Record<string, number>) -
    cluster ID から、その cluster で flush が完了した時点の hybrid timestamp へのマッピングです。

  • flush_all_msgs (Record<string, any>) -
    physical channel 名から、ストレージレイヤーで使用される flush メタデータへのマッピングです。

  • cluster_info (FlushClusterInfo) -
    flush に参加した cluster トポロジーです。

    • cluster_id (string) -

      cluster 識別子です。

    • cchannel (string) -

      control channel 名です。

    • pchannels (string[]) -

      flush の対象となる physical channel です。

  • 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.flushAll();