本文为您介绍如何使用Java开发自定义Processor。

接口定义

使用Java开发自定义Processor仅需要定义一个类,该类中除构造函数以外,只需要 Load()Process()函数即可。类的原型如下。
package com.alibaba.eas;
import java.util.*;
public class TestProcessor {
  public TestProcessor(String modelEntry, String modelConfig) {
    /*传递模型文件名,可以添加初始化工作。*/
  }
  public void Load() {
    /*根据模型名加载模型信息。*/
  }
  public byte[] Process(byte[] input) {
    /*对输入数据进行预测处理并返回结果。支持BYTE[]和STRING,推荐使用BYTE[],可以避免编码问题。*/
  }
  public static void main(String[] args) {
    /*主函数为非必选,可以在本地单机验证类功能。*/
  }
}
如果抛出异常,框架会捕获该异常,并将Exception中的 message作为错误信息返回给客户端,同时HTTP响应400。您也可以自己捕获异常,输出自己的异常错误信息,示例如下。
try{
} catch (com.alibaba.fastjson.JSONException e) {
  throw new RuntimeException("bad json format, " + e.getMessage());
}

单机开发调试

单机调试功能用于非集群模式,用户在本地环境中对模型或Processor进行开发及调试,其开发接口及调用接口与线上集群环境完全兼容。该功能不仅可以避免您在开发测试阶段频繁部署新服务,而且可以节省调试所用的资源费用。
说明 该功能依赖于Docker,需要在运行EASCMD的服务器上预装Docker。如果需要GPU及CUDA,则必须预先在本地安装CUDA及Nvidia-Docker。
单机调试的方法如下:
  1. 如果未安装Docker,则参见Docker安装进行安装。
  2. 下载客户端工具EASCMD,各版本的下载地址如下:
  3. 创建服务配置文件。
    在配置文件中,指定需要部署的模型和编写的Processor,示例如下。
    {
      "name": "diy_test",
      "generate_token": "true",
      "model_path": "http://examplebucket.oss-cn-hangzhou-zmf.aliyuncs.com/scorecard.pmml", #支持HTTP路径或本地路径(仅用于本地调试)。
      "processor_path": "./diy_processor_release.tar.gz", #支持HTTP路径或本地路径(仅用于本地调试),解压后为java processor编译的jar包。
      "processor_mainclass": "com.alibaba.eas.TestProcessor", #java processor中实现Load()和Process()的主类名。
      "processor_type": "java",
      "metadata": {
         "resource": "eas-r-9lkbl2jvdm0puv****", #resource字段表示使用专属资源组部署服务。
         "instance": 1,
         "cpu": 1,
         "memory": 2000
      }
    }
    相关字段说明请参见 命令使用说明
  4. 部署调试。
    sudo eascmd test service.json