[説明] このページは機械翻訳された日本語版です。内容に誤りがございましたら、報告していただけると助かります。

グローバルクラスターへの接続

グローバルクラスターが実行されたら、エンドポイントと認証トークンを使用して接続します。このページでは、2つのエンドポイントタイプ、それぞれの使用場面、およびスイッチオーバーとフェイルオーバー時のルーティング動作について説明します。

📘Notes

この機能は、ビジネスクリティカルプロジェクトのDedicatedクラスターでのみ利用可能です。

エンドポイントタイプの選択

グローバルクラスターは、2つの接続方法を提供します。

• グローバルエンドポイント経由

• グローバルクラスター内のプライマリークラスターまたはセカンダリークラスターのパブリックまたはプライベートエンドポイント経由

次の表は、2つの接続エンドポイントを比較しています。

	グローバルエンドポイント	プライマリークラスターまたはセカンダリークラスターのエンドポイント
書き込みルーティング	プライマリークラスターに自動的にルーティング	プライマリーのパブリックエンドポイントのみが書き込みを受け付ける
読み込みルーティング	プライマリークラスターにルーティング （レイテンシーに基づく最も近い利用可能なクラスターへのインテリジェントルーティングは、近日対応予定です。）	接続した特定のクラスターに読み込みが行われる
スイッチオーバー / フェイルオーバー	自動的に再ルーティング — コード変更は不要	新しいプライマリーを指すように接続を更新する必要がある
プライベートリンク	非対応（パブリックインターネットが必要）	対応
最適な用途	自動フェイルオーバーとレイテンシーベースのルーティングが必要な本番アプリケーション	特定のクラスターへの直接アクセス（例：環境レプリケーション、テスト、デバッグ）

📘Notes

本番ワークロードにはグローバルエンドポイントの使用を推奨します。これにより、スイッチオーバーまたはフェイルオーバー時にアプリケーションコードでエンドポイントの変更を処理する必要がなくなります。

エンドポイントとトークンの取得

1

グローバルクラスターまたは対象のクラスターに移動します。

• グローバルエンドポイントの場合：グローバルクラスターページに移動します。

• パブリックエンドポイントの場合：特定のプライマリークラスターまたはセカンダリークラスターのクラスター詳細ページに移動します。

2

Connect カードで、グローバルエンドポイントまたはパブリックエンドポイントをコピーします。

3

認証トークンを準備します。これは API キー または クラスター認証情報（username:password）のいずれかです。

SDK バージョンの確認

インストールした SDK があることを確認してください。グローバルクラスターに接続する前に、SDK が最低バージョン要件を満たしていることを確認してください。

SDK	最低バージョン
Python	2.6.9
Node.js	2.6.10
Java	2.6.14
Go	2.6.2

グローバルエンドポイントを使用した接続

グローバルエンドポイントは、グローバルクラスター内の適切なクラスターにリクエストをルーティングする単一の URL です。SDK クライアントの uri として使用します。

Python

from pymilvus import MilvusClient

# Use the global endpoint for automatic routing
client = MilvusClient(
    uri="YOUR_GLOBAL_ENDPOINT",  # Global endpoint from the console
    token="YOUR_CLUSTER_TOKEN"   # API key or username:password
)

Java

import io.milvus.v2.client.MilvusClientV2;
import io.milvus.v2.client.ConnectConfig;

// Use the global endpoint for automatic routing
ConnectConfig connectConfig = ConnectConfig.builder()
    .uri("YOUR_GLOBAL_ENDPOINT")  // Global endpoint from the console
    .token("YOUR_CLUSTER_TOKEN")  // API key or username:password
    .build();

MilvusClientV2 client = new MilvusClientV2(connectConfig);

NodeJS

const { MilvusClient } = require("@zilliz/milvus2-sdk-node")

// Use the global endpoint for automatic routing
const client = new MilvusClient({
    address: "YOUR_GLOBAL_ENDPOINT",  // Global endpoint from the console
    token: "YOUR_CLUSTER_TOKEN"       // API key or username:password
})

Go

import "github.com/milvus-io/milvus/client/v2/milvusclient"

// Use the global endpoint for automatic routing
client, err := milvusclient.New(ctx, &milvusclient.ClientConfig{
    Address: "YOUR_GLOBAL_ENDPOINT", // Global endpoint from the console
    APIKey:  "YOUR_CLUSTER_TOKEN", // API key or username:password
})

cURL

curl --request POST \
  --url "YOUR_GLOBAL_ENDPOINT" \
  --header "Authorization: Bearer YOUR_CLUSTER_TOKEN" \
  --header "Content-Type: application/json" \
  --data '{"dbName": "default"}'

Connect using a パブリックエンドポイント

グローバルクラスター内の各クラスターには、それぞれ独自のパブリックエンドポイントがあります。特定のクラスターを直接ターゲットにする必要がある場合は、これを使用してください。

Python

from pymilvus import MilvusClient

# Connect directly to a specific cluster
client = MilvusClient(
    uri="YOUR_CLUSTER_PUBLIC_ENDPOINT",  # Public endpoint of a specific cluster
    token="YOUR_CLUSTER_TOKEN" # API key or username:password
)

Java

import io.milvus.v2.client.MilvusClientV2;
import io.milvus.v2.client.ConnectConfig;

// Connect directly to a specific cluster
ConnectConfig connectConfig = ConnectConfig.builder()
    .uri("YOUR_CLUSTER_PUBLIC_ENDPOINT")  // Public endpoint of a specific cluster
    .token("YOUR_CLUSTER_TOKEN")  // API key or username:password
    .build();

MilvusClientV2 client = new MilvusClientV2(connectConfig);

NodeJS

const { MilvusClient } = require("@zilliz/milvus2-sdk-node")

// Connect directly to a specific cluster
const client = new MilvusClient({
    address: "YOUR_CLUSTER_PUBLIC_ENDPOINT",  // Public endpoint of a specific cluster
    token: "YOUR_CLUSTER_TOKEN"  // API key or username:password
})

Go

import "github.com/milvus-io/milvus/client/v2/milvusclient"

// Connect directly to a specific cluster
client, err := milvusclient.New(ctx, &milvusclient.ClientConfig{
    Address: "YOUR_CLUSTER_PUBLIC_ENDPOINT",  // Public endpoint of a specific cluster
    APIKey:  "YOUR_CLUSTER_TOKEN",  // API key or username:password
})

cURL

curl --request POST \
  --url "YOUR_CLUSTER_PUBLIC_ENDPOINT" \
  --header "Authorization: Bearer YOUR_CLUSTER_TOKEN" \
  --header "Content-Type: application/json" \
  --data '{"dbName": "default"}'

📘Notes

パブリックエンドポイントを使用する場合、書き込み操作を受け付けるのはプライマリークラスターのパブリックエンドポイントのみです。セカンダリークラスターのパブリックエンドポイントへの書き込みは失敗します。

Routing behavior

During normal operation

Request type	グローバルエンドポイント	パブリックエンドポイント
Write (insert, upsert, delete)	Routed to the プライマリークラスター	Only accepted on the プライマリークラスター's endpoint
Read (search, query)	Routed to the プライマリークラスター (Intelligent routing to the nearest available cluster based on latency will be supported soon.)	Served by the specific cluster you connect to

During and after switchover / failover

Scenario	グローバルエンドポイント	パブリックエンドポイント
スイッチオーバー in progress	Writes briefly paused, then resume on the new primary. Reads continue.	No change to endpoints. Old primary becomes secondary.
フェイルオーバー in progress	Writes unavailable until new primary is promoted. Reads continue on secondaries.	Old primary's endpoint becomes unreachable.
After completion	Automatically routes to the new primary. No code changes.	Update your code to use the new primary's パブリックエンドポイント for writes.

SDK automatic reconnection

グローバルエンドポイントを使用する場合、Zilliz Cloud SDK はスイッチオーバーおよびフェイルオーバー中のエンドポイントの再ルーティングを処理します。アプリケーション側でルーティング変更に対するリトライロジックを実装する必要はありません。ただし、切り替え時点で進行中の書き込みは一時的なエラーを受ける可能性があります。これらのケースは、アプリケーション内の標準的なリトライロジックで処理されます。