第 11 章 PMML 模型执行

�程

1. 在客户端应用程序中，将以下依赖项添加到 Java 项目的相关类路径中：

   <!-- Required for the PMML compiler -->
   <dependency>
     <groupId>org.drools</groupId>
     <artifactId>kie-pmml</artifactId>
     <version>${rhpam.version}</version>
   </dependency>
   
   <!-- Required for the KIE public API -->
   <dependency>
     <groupId>org.kie</groupId>
     <artifactId>kie-api</artifactId>
     <version>${rhpam.version}</version>
   </dependencies>
   
   <!-- Required if not using classpath KIE container -->
   <dependency>
     <groupId>org.kie</groupId>
     <artifactId>kie-ci</artifactId>
     <version>${rhpam.version}</version>
   </dependency>

   Copy to Clipboard Toggle word wrap

   & lt;version > 是项目中当前使用的 Red Hat Process Automation Manager 的 Maven 工件版本（如 7.44.0.Final-redhat-00006）。

   注意

   考虑将 Red Hat Business Automation Manager (BOM)依赖项添加到项目 pom.xml 文件，而不是为单个依赖项指定 Red Hat Process Automation Manager < version >。Red Hat Business Automation BOM 适用于 Red Hat Decision Manager 和 Red Hat Process Automation Manager。当您添加 BOM 文件时，项目中包含了来自提供的 Maven 存储库传输性依赖关系的正确版本。

   BOM 依赖项示例：

   <dependency>
     <groupId>com.redhat.ba</groupId>
     <artifactId>ba-platform-bom</artifactId>
     <version>7.9.1.redhat-00003</version>
     <scope>import</scope>
     <type>pom</type>
   </dependency>

   Copy to Clipboard Toggle word wrap

   有关 Red Hat Business Automation BOM 的更多信息，请参阅 RHPAM 产品和 maven 库版本之间的映射是什么？

2. 从 classpath 或 ReleaseId 创建 KIE 容器：

   KieServices kieServices = KieServices.Factory.get();
   
   ReleaseId releaseId = kieServices.newReleaseId( "org.acme", "my-kjar", "1.0.0" );
   KieContainer kieContainer = kieServices.newKieContainer( releaseId );

   Copy to Clipboard Toggle word wrap

   其它选项：

   KieServices kieServices = KieServices.Factory.get();
   
   KieContainer kieContainer = kieServices.getKieClasspathContainer();

   Copy to Clipboard Toggle word wrap

3. 创建 PMMLRequestData 类实例，它将 PMML 模型应用到一组数据：

   public class PMMLRequestData {
       private String correlationId; 

   1

   
       private String modelName; 

   2

   
       private String source; 

   3

   
       private List<ParameterInfo<?>> requestParams; 

   4

   
       ...
   }

   Copy to Clipboard Toggle word wrap

   1

   标识与特定请求或结果关联的数据

   2

   应该应用到请求数据的模型名称

   3

   由内部生成的 PMMLRequestData 对象用来识别所生成的请求的片段

   4

   发送输入数据点的默认机制

4. 创建 PMML4Result 类的实例，其中包含将基于 PMML 的规则应用到输入数据的输出信息：

   public class PMML4Result {
       private String correlationId;
       private String segmentationId; 

   1

   
       private String segmentId; 

   2

   
       private int segmentIndex; 

   3

   
       private String resultCode; 

   4

   
       private Map<String, Object> resultVariables; 

   5

   
       ...
   }

   Copy to Clipboard Toggle word wrap

   1

   当模型类型是 MiningModel 时使用。segmentationId 用于区分多个分段。

   2

   与 segmentationId 一起使用，以识别生成结果的片段。

   3

   用于维护片段的顺序。

   4

   用于确定模型是否已成功应用，其中 OK 表示成功。

   5

   包含结果变量的名称及其关联的值。

   除了正常的 getter 方法外，pmML4Result 类还支持以下方法直接检索结果变量的值：

   public <T> Optional<T> getResultValue(String objName, String objField, Class<T> clazz, Object...params)
   
   public Object getResultValue(String objName, String objField, Object...params)

   Copy to Clipboard Toggle word wrap

5. 创建 ParameterInfo 类的实例，用作作为 PMMLRequestData 类一部分的基本数据类型对象的打包程序：

   public class ParameterInfo<T> { 

   1

   
       private String correlationId;
       private String name; 

   2

   
       private String capitalizedName;
       private Class<T> type; 

   3

   
       private T value; 

   4

   
       ...
   }

   Copy to Clipboard Toggle word wrap

   1

   处理许多不同类型的参数类

   2

   期望作为模型输入的变量名称

   3

   变量的实际类型的类

   4

   变量的实际值

6. 根据您创建的所需的 PMML 类实例执行 PMML 模型：

   public void executeModel(KieBase kbase,
                            Map<String,Object> variables,
                            String modelName,
                            String correlationId,
                            String modelPkgName) {
       RuleUnitExecutor executor = RuleUnitExecutor.create().bind(kbase);
       PMMLRequestData request = new PMMLRequestData(correlationId, modelName);
       PMML4Result resultHolder = new PMML4Result(correlationId);
       variables.entrySet().forEach( es -> {
           request.addRequestParam(es.getKey(), es.getValue());
       });
   
       DataSource<PMMLRequestData> requestData = executor.newDataSource("request");
       DataSource<PMML4Result> resultData = executor.newDataSource("results");
       DataSource<PMMLData> internalData = executor.newDataSource("pmmlData");
   
       requestData.insert(request);
       resultData.insert(resultHolder);
   
       List<String> possiblePackageNames = calculatePossiblePackageNames(modelName,
                                                                       modelPkgName);
       Class<? extends RuleUnit> ruleUnitClass = getStartingRuleUnit("RuleUnitIndicator",
                                                                   (InternalKnowledgeBase)kbase,
                                                                   possiblePackageNames);
   
       if (ruleUnitClass != null) {
           executor.run(ruleUnitClass);
           if ( "OK".equals(resultHolder.getResultCode()) ) {
             // extract result variables here
           }
       }
   }
   
   protected Class<? extends RuleUnit> getStartingRuleUnit(String startingRule, InternalKnowledgeBase ikb, List<String> possiblePackages) {
       RuleUnitRegistry unitRegistry = ikb.getRuleUnitRegistry();
       Map<String,InternalKnowledgePackage> pkgs = ikb.getPackagesMap();
       RuleImpl ruleImpl = null;
       for (String pkgName: possiblePackages) {
         if (pkgs.containsKey(pkgName)) {
             InternalKnowledgePackage pkg = pkgs.get(pkgName);
             ruleImpl = pkg.getRule(startingRule);
             if (ruleImpl != null) {
                 RuleUnitDescr descr = unitRegistry.getRuleUnitFor(ruleImpl).orElse(null);
                 if (descr != null) {
                     return descr.getRuleUnitClass();
                 }
             }
         }
       }
       return null;
   }
   
   protected List<String> calculatePossiblePackageNames(String modelId, String...knownPackageNames) {
       List<String> packageNames = new ArrayList<>();
       String javaModelId = modelId.replaceAll("\\s","");
       if (knownPackageNames != null && knownPackageNames.length > 0) {
           for (String knownPkgName: knownPackageNames) {
               packageNames.add(knownPkgName + "." + javaModelId);
           }
       }
       String basePkgName = PMML4UnitImpl.DEFAULT_ROOT_PACKAGE+"."+javaModelId;
       packageNames.add(basePkgName);
       return packageNames;
   }

   Copy to Clipboard Toggle word wrap

   规则由 RuleUnitExecutor 类执行。RuleUnitExecutor 类创建 KIE 会话，并将所需的 DataSource 对象添加到这些会话中，然后根据作为参数传递给 run （） 方法的 RuleUnit 执行规则。calculatePossiblePackageNames 和 getStartingRuleUnit 方法决定传递给 run （） 方法的 RuleUnit 类的完全限定名称。