get_replicate_info()

This operation gets the replication checkpoint state for a source cluster and source pchannel.

Request Syntax

python

get_replicate_info(
    source_cluster_id: str,
    target_pchannel: str,
    timeout: Optional[float] = None,
    **kwargs
)

PARAMETERS:

• source_cluster_id (str) -

  [REQUIRED]

  The ID of the source cluster.

• target_pchannel (str) -

  [REQUIRED]

  The name of the physical channel in the source cluster.

• timeout (Optional[float]) -

  The maximum time, in seconds, to wait for the RPC to complete.

• kwargs (Any) -

  Additional request context options.

EXCEPTIONS:

• MilvusException

  Raised when the server rejects the request or the RPC fails. Inspect the server error message for the exact failure reason.

Examples

python

from pymilvus import MilvusClient

client = MilvusClient(uri="YOUR_CLUSTER_ENDPOINT")
info = client.get_replicate_info(
    source_cluster_id="source-1",
    target_pchannel="by-dev-rootcoord-dml_0",
)