Platform For AI:Call a service over a VPC direct connection

Python SDK

1. Install or upgrade the SDK:

      pip install -U eas-prediction --user

2. Call the service using TensorFlow request format. For other formats, see Python SDK guide.

   PredictClient constructor requires the VPC direct connection endpoint and service name. Call set_endpoint_type(ENDPOINT_TYPE_DIRECT) to enable VPC direct connection, then call init() to initialize.

      #!/usr/bin/env python
      from eas_prediction import PredictClient
      from eas_prediction import StringRequest
      from eas_prediction import TFRequest
      from eas_prediction import ENDPOINT_TYPE_DIRECT
   
      # VPC direct connection endpoint: {Uid}.vpc.{RegionId}.pai-eas.aliyuncs.com
      # Replace with your account ID and region
      ENDPOINT = "123**********.vpc.cn-shanghai.pai-eas.aliyuncs.com"
   
      # Replace with your EAS service name
      SERVICE_NAME = "mnist_saved_model_example"
   
      # Replace with your service token from the service details page
      # Store tokens in environment variables or KMS, not in code
      TOKEN = "M2FhNjJlZDBmMzBmMzE4NjFiNzZhMmUxY2IxZjkyMDczNzAzYjFi****"
   
      if __name__ == '__main__':
          client = PredictClient(ENDPOINT, SERVICE_NAME)
          client.set_token(TOKEN)
          client.set_endpoint_type(ENDPOINT_TYPE_DIRECT)  # Enable VPC direct connection
          client.init()
   
          req = TFRequest('predict_images')
          req.add_feed('images', [1, 784], TFRequest.DT_FLOAT, [1] * 784)
          resp = client.predict(req)
          print(resp)

Java SDK

1. Add Maven dependency to the pom.xml file. For the latest version, see Maven repository. For details, see Java SDK guide.

      <dependency>
        <groupId>com.aliyun.openservices.eas</groupId>
        <artifactId>eas-sdk</artifactId>
        <version>2.0.20</version>
      </dependency>

2. Call the service.

      import com.aliyun.openservices.eas.predict.http.PredictClient;
      import com.aliyun.openservices.eas.predict.http.HttpConfig;
   
      public class TestString {
          public static void main(String[] args) throws Exception {
              // Create and initialize the client once at startup
              // Do not create a new client for each request
              PredictClient client = new PredictClient(new HttpConfig());
   
              // Replace with your service token from the service details page
              client.setToken("YWFlMDYyZDNmNTc3M2I3MzMwYmY0MmYwM2Y2MTYxMTY4NzBkNzdj****");
   
              // Set VPC direct connection endpoint: {Uid}.vpc.{RegionId}.pai-eas.aliyuncs.com
              // Replace with your account ID and region
              client.setDirectEndpoint("123**********.vpc.cn-shanghai.pai-eas.aliyuncs.com");
   
              // Replace with your EAS service name
              client.setModelName("scorecard_pmml_example");
   
              // Define input string
              String request = "[{\"money_credit\": 3000000}, {\"money_credit\": 10000}]";
              System.out.println(request);
   
              // Send prediction request
              try {
                  String response = client.predict(request);
                  System.out.println(response);
              } catch (Exception e) {
                  e.printStackTrace();
              }
   
              // Shut down client when finished
              client.shutdown();
          }
      }

Go SDK

Go package manager downloads the SDK automatically during compilation. For details, see Go SDK guide.

package main

import (
    "fmt"
    "github.com/pai-eas/eas-golang-sdk/eas"
)

func main() {
    // VPC direct connection endpoint: {Uid}.vpc.{RegionId}.pai-eas.aliyuncs.com
    // Replace with your account ID, region, and service name
    client := eas.NewPredictClient("123**********.vpc.cn-shanghai.pai-eas.aliyuncs.com", "scorecard_pmml_example")

    // Replace with your service token from the service details page
    client.SetToken("YWFlMDYyZDNmNTc3M2I3MzMwYmY0MmYwM2Y2MTYxMTY4NzBkNzdj****")
    client.SetEndpointType(eas.EndpointTypeDirect)
    client.Init()

    req := "[{\"fea1\": 1, \"fea2\": 2}]"
    for i := 0; i < 100; i++ {
        resp, err := client.StringPredict(req)
        if err != nil {
            fmt.Printf("failed to predict: %v\n", err.Error())
        } else {
            fmt.Printf("%v\n", resp)
        }
    }
}