flushAll()
この操作はすべての collection を flush し、すべての segment を sealed にして、データをディスクに永続化します。
await milvusClient.flushAll(data?: FlushAllReq)
リクエスト構文
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 を返します。
{
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) -
報告されたエラーの理由を示す理由です。この操作が成功した場合は空文字列のままです。
-
例
import { MilvusClient } from '@zilliz/milvus2-sdk-node';
const client = new MilvusClient({
address: 'YOUR_CLUSTER_ENDPOINT',
token: 'YOUR_CLUSTER_TOKEN',
});
const res = await client.flushAll();