AbortImportOption

AbortImportOption インスタンスは、RESTful API を介して一括インポートジョブを中断するリクエストを構成します。

Notes

セルフホスト型 Milvus の場合は NewAbortImportOption() で、Zilliz Cloud の場合は NewCloudAbortImportOption() で構築します。

Notes

WithAPIKey() をチェーンして認可トークンを追加します。

go
type AbortImportOption struct {
    URL string
    JobID string
    ClusterID string
    APIKey string
}

フィールド：

URL (string) -

Milvus または Zilliz Cloud クラスターのベース URL です。パスは含めないでください。関数は /v2/vectordb/jobs/import/abort を自動的に追加します。
JobID (string) -

中断するインポートジョブの一意の識別子です。BulkImport() から返される値を渡します。必須です。
ClusterID (string) -

Zilliz Cloud のクラスター ID です。省略可能です。クラウドインポートでのみ使用されます。
APIKey (string) -

Bearer ヘッダーとして送信される認可トークンです。省略可能です。サーバーがトークンベースの認証を適用する場合は必須です。

ビルダーメソッド：

WithAPIKey(key string)

Bearer ヘッダーとして送信する認可トークンを設定します。
NewAbortImportOption(uri string, jobID string)

AbortImport() 用のリクエストを作成します。
NewCloudAbortImportOption(uri string, jobID string, apiKey string, clusterID string)

Zilliz Cloud に対する AbortImport() 用のリクエストを作成します。

メソッド：

GetRequest() ([]byte, error)

例

AbortImportOption の使用例を示します。

go
import (
	"context"

	"github.com/milvus-io/milvus/client/v3/milvusclient"
)

ctx, cancel := context.WithCancel(context.Background())
defer cancel()

cli, err := milvusclient.New(ctx, &milvusclient.ClientConfig{
	Address: "YOUR_CLUSTER_ENDPOINT",
})
if err != nil {
	// handle error
}
defer cli.Close(ctx)

err := cli.AbortImport(ctx, milvusclient.NewAbortImportOption("<jobId>"))
if err != nil {
	// handle error
}

例​

例