Platform For AI:gRPC を介した PAI-EAS 推論サービスの呼び出し

package main

import (
	"context"
	"log"
	"time"

	pb "your-project/proto"

	"google.golang.org/grpc"
	"google.golang.org/grpc/credentials/insecure"
	"google.golang.org/grpc/metadata"
)

func main() {
	// gRPC エンドポイントに置き換えます。PAI-EAS コンソールの呼び出し情報パネルで確認できます。
	// パブリックネットワークのエンドポイント形式は、service-name.{uid}.{region}.pai-eas.aliyuncs.com:80 です (ポートは 80 に固定)。
	host := "お使いのサービスエンドポイント:ポート番号"
	// サービストークンに置き換えます。PAI-EAS コンソールのサービス詳細ページで確認できます。
	token := "お使いのサービストークン"

	log.Printf("PAI-EAS gRPC サービス (%s) に接続しています...", host)
        
        // 1. 接続を確立します。接続はスレッドセーフです。1 つの接続を作成し、それを再利用することを推奨します。
	conn, err := grpc.NewClient(
		host,
		grpc.WithTransportCredentials(insecure.NewCredentials()),
	)
	if err != nil {
		log.Fatalf("接続に失敗しました： %v", err)
	}
	defer conn.Close()

	// 2. クライアントを作成します。
	client := pb.NewGreeterServiceClient(conn)
	
	// 3. gRPC メタデータを使用して認証トークンを設定します。
	md := metadata.Pairs("authorization", "Bearer " + token)

	ctx := metadata.NewOutgoingContext(context.Background(), md)

	// 4. タイムアウトを設定します。
	ctx, cancel := context.WithTimeout(ctx, 5*time.Second)
	defer cancel()

	// 5. リクエストを構築します。
	req := &pb.HelloRequest{Name: "World"}

	// 6. 呼び出します。
	resp, err := client.SayHello(ctx, req)
	if err != nil {
		log.Fatalf("呼び出しに失敗しました： %v", err)
	}

	log.Printf("受信したレスポンス： %s", resp.Message)
}

import grpc
import helloworld_pb2
import helloworld_pb2_grpc

# gRPC エンドポイントに置き換えます。PAI-EAS コンソールの呼び出し情報パネルで確認できます。
# パブリックネットワークのエンドポイント形式は、service-name.{uid}.{region}.pai-eas.aliyuncs.com:80 です (ポートは 80 に固定)。
host = "お使いのサービスエンドポイント:ポート番号"
# サービストークンに置き換えます。PAI-EAS コンソールのサービス詳細ページで確認できます。
token = "お使いのサービストークン"

# 1. サーバーに接続するためのチャネルを作成します。
channel = grpc.insecure_channel(host)

# 2. スタブ (クライアントハンドル) を初期化します。
stub = helloworld_pb2_grpc.GreeterServiceStub(channel)

# 3. リクエストを構築します。
request = helloworld_pb2.HelloRequest(name="World")

# 4. PAI-EAS サービスにトークンを渡すための認証メタデータを構築します。
metadata = (("authorization",  "Bearer " + token),)

print("gRPC 呼び出しを開始しています...")

try:
    # 5. 同期リクエストを実行します。認証のためにメタデータを渡します。
    response = stub.SayHello(request, metadata=metadata, timeout=5.0)
    print(response.message)
except grpc.RpcError as e:
    print(f"呼び出しに失敗しました： {e.code()} - {e.details()}")
finally:
    channel.close()