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

get_import_progress()

この関数は、バルクインポートジョブの現在のステータスを返します。

リクエスト構文​

python
get_import_progress(
    url: str,
    job_id: str,
    cluster_id: str = "",
    project_id: str = "",
    region_id: str = "",
    api_key: str = "",
    db_name: str = "",
    verify: Optional[Union[bool, str]] = True,
    cert: Optional[Union[str, tuple]] = None,
    **kwargs,
) -> requests.Response

パラメータ:

  • url (str) -
    [必須]

    Zilliz Cloud API サーバーのエンドポイントは、https://api.cloud.zilliz.com です。

  • job_id (str) -
    [必須]
    確認するインポートジョブの ID です。

  • cluster_id (str) -
    デフォルト: ""
    対象の Zilliz Cloud クラスターの ID です。

  • project_id (str) -
    デフォルト: ""
    対象のプロジェクトデータベースを含む Zilliz Cloud プロジェクトの ID です。

  • region_id (str) -
    デフォルト: ""
    対象のプロジェクトデータベースを含む Zilliz Cloud リージョンの ID です。

  • api_key (str) -
    デフォルト: ""

    リクエストの認証に使用する Zilliz Cloud API キーです。

  • db_name (str) -
    デフォルト: ""
    ロールベースのアクセス制御のために DB-Name ヘッダーで送信されるデータベース名です。

  • verify (Optional[Union[bool, str]]) -
    デフォルト: True
    TLS 検証の設定です。True を使用してデフォルトのトラストストアで検証するか、CA 証明書のパスを指定します。

  • cert (Optional[Union[str, tuple]]) -
    デフォルト: None
    クライアント証明書のパス、または相互 TLS 用の証明書と秘密鍵のペアです。

  • kwargs (Any) -
    HTTP リクエストに転送される追加オプションです。

戻り値の型:

requests.Response

戻り値:

現在のバルクインポートジョブの状態と進行状況を含む HTTP レスポンスです。

例外:

  • MilvusException
    サーバーがリクエストを拒否した場合、または RPC が失敗した場合に発生します。正確な失敗の詳細については、サーバーのエラーメッセージを確認してください。

使用例​

この例では、Zilliz Cloud からインポートの進行状況を取得します。

python
from pymilvus.bulk_writer import get_import_progress

response = get_import_progress(
    url="https://api.cloud.zilliz.com",
    api_key="YOUR_API_KEY",
    project_id="proj-xxxx",
    region_id="aws-us-west-2",
    job_id="job-123",
)
print(response.json())
Ctrl I