后台审核管理 ergo_Kogito，ergo规则：从知识到服务，轻松自如

小咪咪 2023-02-25 03:49 11阅读 0赞

后台审核管理 ergo

欢迎阅读有关Kogito倡议的博客系列的另一集，以及我们将Drools带入云的努力。 这些文章的目的是收集用户对我们提供给Kogito的功能的早期反馈。

在本文中，我们介绍了**两种**实现完整智能服务的**新方法** ：

1.  独立的规则服务
2.  集成智能工作流程和规则任务

## Kogito的执行单位 ##

您可能已经知道，在Kogito中，我们正在使全新的[Unit][]概念成为中心。

“执行单元”是我们用来表示可执行知识的术语。 一个单元可以是一个过程，一组规则，一个决策等。在一组规则的情况下，我们称其为*规则单元* 。 如果您选择使用单位，则**在Kogito中，**我们将照顾自动生成**REST端点**所需的所有样板。

规则单元主要由

1）数据定义；  
  
2）一组实现单元行为的规则和查询（规则引擎的规则）； 3）可选地，可以出于多种目的附加事件监听器。

在本文中，我们将重点介绍数据定义，规则和查询。

通过声明一个可能包含数据源的Java类来给出**数据定义** 。 每个数据源代表规则将匹配或插入到其中的工作内存分区。

例如，假设您要声明一个警报服务，该服务接收事件并根据某些条件产生警报。 我们声明  
`Event`和`Alert`对象如下：

package com.acme;  public class Event { 
        String type; 
        int value; 
        // getters and setters  }  public class Alert { 
       String severity; 
       String message; 
       // getters and setters  }

`AlertingService`单元类型声明是实现接口`RuleUnitData` 。

package com.acme;  public class AlertingService implements RuleUnitData { 
        private final DataStream<Event> eventData = DataSource.createStream(); 
        private final DataStream<Alert> alertData = DataSource.createStream(); 
        // getters and setters  }

**规则**通常在DRL文件中定义，除了现在必须在文件顶部指示它们的**单位** 。 例如，您可以按以下方式声明`AlertingService`的数据定义：

package com.acme;  unit AlertingService;  rule IncomingEvent when 
        // matches when a temperature higher than 30 °C is registered (OOPath syntax) 
        $e : /eventData [ type == "temperature" , value >= 30 ]  then 
        System.out.println( "incoming event: " + $e.getMessage()); 
        alertData.append( new Alert( "warning" , "Temperature is too high" ) );  end

如您所见，规则可能与给定的数据源匹配或插入到给定的数据源。

**查询**是在DRL文件（如规则）中定义的，也属于一个单元。 如果声明至少一个查询，则将免费获得**REST端点自动生成** 。 例如：

query Warnings 
        alerts: /alertData [ severity == "warning" ]  end

将生成REST终结点`/warnings` ，您可以通过以下方式对其进行POST-ing调用：

$ curl -X POST \ 
                -H 'Accept: application/json' \ 
                -H 'Content-Type: application/json' \ 
                -d '{ "eventData": [ { "type": "temperature", "value" : 40 } ] }' \ 
                http: //localhost:8080/warnings

这将生成响应：

[ { "severity" : "warning" , "message" : "Temperature is too high" } ]

程序员非常熟悉基于Java的数据定义，但是从用户的早期反馈来看， *我们决定提供两种替代方法来声明规则单元* 。 我们正在发布此博客文章，以收集更多的用户反馈！

## 类型声明 ##

*类型声明*是DRL功能，用于以与Java无关的方式声明与Java兼容的类型。 在7系列中，用户可以使用以下语法声明类型：

package com.acme;  declare Event 
        type: String 
        value: int  end  declare Alert 
       severity: String 
       message: String  end

这使DRL完全独立：可以使用DRL定义实体和规则。 但是，它们没有什么限制。 例如，它们不支持实现接口，也不支持泛型类型字段。 换句话说，以下声明在7系列中在语法上是无效的：

package com.acme;  declare AlertingService extends RuleUnitData 
        eventData: DataStream<Event> 
        alertData: DataStream<Alert>  end

在版本0.8.0中，我们解除了这些限制：我们允许接口的继承受限（现在仅允许一个继承），而字段的通用类型声明。 有了这些新功能，以下代码将成为有效的DRL。

长话短说： **您现在可以声明完整的微服务**   
 **来自单个DRL** 。

使用原型引导您的Kogito服务：

mvn archetype:generate \ 
              -DarchetypeGroupId=org.kie.kogito \ 
              -DarchetypeArtifactId=kogito-quarkus-archetype \ 
              -DarchetypeVersion= 0.8 . 0 \ 
              -DgroupId=com.acme \ 
              -DartifactId=sample-kogito

目前，没有Quarkus版本捆绑Kogito 0.8.0。 否则，您将可以使用`mvn io.quarkus:quarkus-maven-plugin:create`代替。

现在，清除`src/main`的内容，然后将此DRL放到`src/main/resources/com/acme`文件夹中：

package com.acme;  unit AlertingService;  import org.kie.kogito.rules.DataStream;  import org.kie.kogito.rules.RuleUnitData;  declare Event 
        type: String 
        value: int  end  declare Alert 
       severity: String 
       message: String  end  declare AlertingService extends RuleUnitData 
        eventData: DataStream<Event> 
        alertData: DataStream<Alert>  end  rule IncomingEvent when 
        // matches when a temperature higher than 30 °C is registered (OOPath syntax) 
        $e : /eventData [ type == "temperature" , value >= 30 ]  then 
        System.out.println( "incoming event: " + $e.getMessage()); 
        alertData.append( new Alert( "warning" , "Temperature is too high: " + $e ) );  end  query Warnings 
        alerts: /alertData [ severity == "warning" ]  end

现在，以以下方式在开发人员模式下启动Quarkus服务：

$ mvn compile quarkus:dev

到此为止，您现在可以`curl`您的服务了：

## 工作流程整合 ##

公开基于规则的服务的另一种方法是通过*工作流* 。

*工作流* （有时称为“业务流程”）描述了图中的一系列步骤，并且通常会声明*变量* ：在执行过程中操作的值的数据持有者。 一个这样的变量的数据类型可以是*任何东西* ：您可以使用Java类，但是在此示例中，我们将再次使用声明的数据类型。

package com.acme;  declare Event 
        type: String 
        value: int  end  declare Alert 
       severity: String 
       message: String  end

让我们将此工作流称为`com.acme.AlertingWorkflow` ，并声明变量`eventData`和`alertData` ：

![format_png][]

包含*规则任务的*工作流可能会完全跳过规则单元的数据*声明* ：在这种情况下，规则单元是直接从流程的结构中推断的：每个变量都将**插入同名的数据源中** 。

![format_png 1][]

单元的*名称*由进程使用语法`unit:com.acme.AlertingService` 。 您仍然可以自由声明单元`com.acme.AlertingService` ； 在这种情况下，该过程将获取您手工编码的声明。

注意：您可能已经注意到我们正在使用“规则流组”字段。 将来，我们将在UI中实现更明确的支持。

使用原型引导您的Kogito服务：

**警告** 。 该功能的支持是试验性的，因此它可能无法与Quarkus热代码重新加载无缝配合； 我们还需要执行以下额外步骤来启用它，但将来会有所改变。

使用以下插件声明更新`pom.xml` ：

<build> 
         <plugins> 
           <plugin> 
             <groupId>org.kie.kogito</groupId> 
             <artifactId>kogito-maven-plugin</artifactId> 
             <version> 0.8 . 0 </version> 
             <executions> 
               <execution> 
                 <goals> 
                   <goal>generateDeclaredTypes</goal> 
                 </goals> 
               </execution> 
             </executions> 
           </plugin> 
           ... 
         </plugins> 
        </build>

现在，您可以清除`src/main`的内容，然后将进程和以下DRL放到`src/main/resources/com/acme`文件夹中。

package com.acme;  unit AlertingService;  import org.kie.kogito.rules.DataStream;  import org.kie.kogito.rules.RuleUnitData;  declare Event 
        type: String 
        value: int  end  declare Alert 
       severity: String 
       message: String  end  rule IncomingEvent when 
        // matches when a temperature higher than 30 °C is registered (OOPath syntax) 
        $e : /eventData [ type == "temperature" , value >= 30 ]  then 
        System.out.println( "incoming event: " + $e.getMessage()); 
        alertData.set( new Alert( "warning" , "Temperature is too high: " + $e ) );  end

您可能已经注意到，不需要显式声明查询：该过程将显示变量的内容作为响应； 它将生成端点`/AlertingWorkflow` ，并接受以下形式的`POST`请求：

$ curl -X POST \ 
                -H 'Accept: application/json' \ 
                -H 'Content-Type: application/json' \ 
                -d '{ "eventData": { "type": "temperature", "value" : 40 } }' \ 
                http: //localhost:8080/AlertingWorkflow

答复将是：

{ 
       "id" : ..., 
       "eventData" : { 
         "type" : "temperature" , 
         "value" : 100 
       }, 
       "alertData" : { 
         "severity" : "warning" , 
         "message" : "Temperature is too high: Event( type=temperature, value=100 )" 
       }  }

但是，如果您*确实*声明了查询，则也可以使用单独的端点。 例如，如果您声明查询“ `Warnings`您仍然可以POST到`http://localhost:8080/warnings`并分别调用规则服务，如下所示：

$ curl -X POST \ 
            -H 'Accept: application/json' \ 
            -H 'Content-Type: application/json' \ 
            -d '{ "eventData": { "type": "temperature", "value" : 40 } }' \ 
            http: //localhost:8080/warnings

请注意，该请求不再包含事件列表。 这是因为过程变量映射到单个值而不是DataStreams。

## 结论 ##

我们偷看了我们正在做的工作，以改进Kogito中的规则和流程的入门经验。 通过这些更改，我们希望提供一种更加简化的方法来定义基于知识的服务。 通过选择编写Java，开发人员将始终能够更加明确地了解他们想要处理的数据。 但如果他们愿意，他们可以采用完全以DSL为中心的开发工作流程。

*对于懒惰，可以在[https://github.com/evacchi/kogito-rules-example/tree/master/code][https_github.com_evacchi_kogito-rules-example_tree_master_code]获得示例。*

> 翻译自: [https://www.javacodegeeks.com/2020/03/kogito-ergo-rules-from-knowledge-to-service-effortless.html][https_www.javacodegeeks.com_2020_03_kogito-ergo-rules-from-knowledge-to-service-effortless.html]

后台审核管理 ergo

[Unit]: http://blog.athico.com/2019/07/kogito-ergo-rules-part-2-all.html
[format_png]: /images/20230209/7f92a6d85b8f4849bf12f375b7c16c6d.png
[format_png 1]: /images/20230209/e06f9a810e994bf68ddc456600742c6f.png
[https_github.com_evacchi_kogito-rules-example_tree_master_code]: https://github.com/evacchi/kogito-rules-example/tree/master/code
[https_www.javacodegeeks.com_2020_03_kogito-ergo-rules-from-knowledge-to-service-effortless.html]: https://www.javacodegeeks.com/2020/03/kogito-ergo-rules-from-knowledge-to-service-effortless.html