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 := "your-service-endpoint:80"
	// ご自身のサービストークンに置き換えてください。PAI-EAS コンソールのサービス詳細ページで確認できます。
	token := "your-service-token"

	log.Printf("Connecting to the PAI-EAS gRPC service (%s)...", host)
        
        // 1. 接続を確立します。接続はスレッドセーフです。1 つの接続を作成して再利用することを推奨します。
	conn, err := grpc.NewClient(
		host,
		grpc.WithTransportCredentials(insecure.NewCredentials()),
	)
	if err != nil {
		log.Fatalf("Failed to connect: %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("Call failed: %v", err)
	}

	log.Printf("Received response: %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 = "your-service-endpoint:80"
# ご自身のサービストークンに置き換えてください。PAI-EAS コンソールのサービス詳細ページで確認できます。
token = "your-service-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("Initiating gRPC call...")

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