메뉴 건너뛰기

Bigdata, Semantic IoT, Hadoop, NoSQL

Bigdata, Hadoop ecosystem, Semantic IoT등의 프로젝트를 진행중에 습득한 내용을 정리하는 곳입니다.
필요한 분을 위해서 공개하고 있습니다. 문의사항은 gooper@gooper.com로 메일을 보내주세요.


* 참고1 : http://opennaru.tistory.com/32

* 참고2 : http://opennaru.tistory.com/31


Drools 6.0 으로 비즈니스 룰을 정의하여 실제 업무에 유사하게 적용할 수 있는 예제를 작성해 봅니다.
예제는 출장 경비를 산출하는 간단한 애플리케이션입니다.

1. Drools 프로젝트를 진행하기 위해 새로운 maven 프로젝트 생성

Drools 프로젝트를 개발하기 위한 디렉터리는 구조는 아래와 같습니다.

20160718_171934.png




pom.xml 설정
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  <modelVersion>4.0.0</modelVersion>
  <groupId>com.gooper</groupId>
  <artifactId>droolsTest</artifactId>
  <version>0.0.1-SNAPSHOT</version>
  
     <dependencies>
        <dependency>
            <groupId>org.drools</groupId>
            <artifactId>drools-compiler</artifactId>
            <version>6.0.0.CR1</version>
        </dependency>
        <dependency>
            <groupId>org.drools</groupId>
            <artifactId>drools-core</artifactId>
            <version>6.0.0.CR1</version>
        </dependency>
        <dependency>
            <groupId>org.slf4j</groupId>
            <artifactId>slf4j-simple</artifactId>
            <version>1.7.2</version>
            <scope>runtime</scope>
         </dependency>        
        
    </dependencies>
</project>



2. 출장 지급 규정에 대한 룰에 대한 정의 파일인 sample.drl 작성


다음과 같이 출장 기간에 따라 출장 경비 지급 금액이 분류 되어 있습니다.

- 1 일 출장 시간이 4시간 미만의 경우 출장 일비 없음
- 4 시간 이상 8시간 미만의 경우 출장 일비는 8만원 
- 8 시간 이상 12시간 미만의 경우 출장 일비는 12 만원
- 12 시간 이상일 때 출장 일비는 20만원 


다음은 위에 정의된 출장 일비 지급 규정을 룰로 정리한 것입니다.

package com.gooper.droolsTest

import com.gooper.droolsTest.BusinessTrip;

rule "출장일비 없음"
    when
              bt:BusinessTrip (hour < 4.0 , name:name )
       then
              System.out.println ( name + " 님의 출장 시간은 "
              + bt.getHour ( ) + " 시간 이므로 출장일비가 없습니다. ( 규정 : 출장일비 없음 ) " ) ;
end


rule "출장일비 C"
       when
              bt:BusinessTrip(hour>=4.0,hour<8.0,name:name)
       then
              System.out.println ( name + " 님의 출장 시간은 "
              + bt.getHour ( ) + " 시간 이므로, 출장일비는 8만원 입니다. ( 규정 : 출장일비 C ) " ) ;
end

rule "출장일비 B"
       when
              bt:BusinessTrip(hour>=8.0 , hour < 12.0 , name :name)
       then
              System.out.println ( name + " 님의 출장 시간은 "
              + bt.getHour ( ) + " 시간 이므로, 출장일비는 12만원 입니다. ( 규정 : 출장일비 B ) " ) ;
end

rule "사용자 찾기"
       when
              bt:BusinessTrip(name == "사용자2", name :name)
       then
              System.out.println ( "사용자2를 찾았네요 ! ");
end


rule "max값 찾기"
       when
              bt:BusinessTrip(maxHour : hour)
              not BusinessTrip(hour > maxHour)
       then
              System.out.println ("출장시간이 가장긴 사람은 "+maxHour+"입니다.");
              System.out.println("출장시간이 가장긴 사람은 "+bt.getName() + "이며 시간은 "+bt.getHour()+"입니다");
end
* max(hour)값 찾기
when 절에서 "maxHour 보다 큰 값을 가진 BusinessTrip은 없다는 룰" 을 적용한다.
자신의 hour보다 큰 hour(maxHour)를 가지는 BusinessTrip은 존재하지 않는 다는 것을 적용하면 max값을 구할 수 있다.


3. BusinessTrip 클래스 작성하기

룰의 대상이 되는 오브젝트를 자바 클래스로 정의합니다. 이 샘플 프로그램에서 룰의 대상이 되는 것은 "출장"이라는 개념이므로 BusinessTrip 클래스를 다음과 같이 작성합니다.

package com.gooper.droolsTest;

public class BusinessTrip {

    private String name;
    private double hour ;
   
    public BusinessTrip(String name, double hour){
      thisname = name;
      thishour  = hour;
    }
     
    public String getName(){
      return name;
    }
   
    public double getHour(){
      return hour;
    }
}
       
4. DroolsTest 클래스를 작성

sample.drl 에 정의된 룰을 테스트하기 위한 애플리케이션을 작성합니다.

package com.gooper.droolsTest;

import org.kie.api.KieBase;
import org.kie.api.io.ResourceType;
import org.kie.api.runtime.KieSession;
import org.kie.internal.builder.KnowledgeBuilder;
import org.kie.internal.builder.KnowledgeBuilderFactory;
import org.kie.internal.io.ResourceFactory;

public class DroolsTest {

        public static final void main(String[] args) {
               try {

                     KnowledgeBuilder kbuilder = KnowledgeBuilderFactory
                                  . newKnowledgeBuilder();
                     kbuilder.add(ResourceFactory. newClassPathResource("sample.drl"),
                                  ResourceType. DRL );

                     KieBase kiebase = kbuilder.newKnowledgeBase();
                     KieSession session = kiebase.newKieSession();

                     session.insert( new BusinessTrip("사용자1" ,3.5));
                     session.insert( new BusinessTrip("사용자2" ,5.0));
                     session.insert( new BusinessTrip("사용자3" ,8.0));
                     session.insert( new BusinessTrip("사용자4" ,10.0));
                     session.insert( new BusinessTrip("사용자5" ,13.0));
                     
                     session.fireAllRules();

              } catch (Throwable t) {
                     t.printStackTrace();
              }
       }
}


5. 출장 경비 지급 규정에 대한 룰 실행 결과

DroolsTest 애플리케이션에 하드 코드로 작성된 각 사용자의 출장 시간을 입력하여 룰 엔진을 통한 결과를 다음과 같이 확인 할 수 있습니다.


사용자4 님의 출장 시간은 10.0 시간 이므로, 출장일비는 12만원 입니다. ( 규정 : 출장일비 B ) 
사용자3 님의 출장 시간은 8.0 시간 이므로, 출장일비는 12만원 입니다. ( 규정 : 출장일비 B ) 
사용자2 님의 출장 시간은 5.0 시간 이므로, 출장일비는 8만원 입니다. ( 규정 : 출장일비 C ) 
사용자2를 찾았네요 ! 
출장시간이 가장긴 사람은 13.0입니다.
출장시간이 가장긴 사람은 사용자5이며 시간은 13.0입니다
사용자1 님의 출장 시간은 3.5 시간 이므로 출장일비가 없습니다. ( 규정 : 출장일비 없음 ) 

번호 제목 글쓴이 날짜 조회 수
301 VisualVM 1.3.9을 이용한 JVM 모니터링 file 총관리자 2016.10.27 333
300 Cleaning up the staging area file시 'cannot access' 혹은 'Directory is not writable' 발생시 조치사항 총관리자 2017.05.02 336
299 sentry설정후 beeline으로 hive2server에 접속하여 admin계정에 admin권한 부여하기 총관리자 2018.07.03 336
298 embedded-cassandra의 data 저장위치 총관리자 2019.06.09 336
297 쿠버네티스(k8s) 설치 및 클러스터 구성하기 총관리자 2019.10.19 337
296 [sqoop] mapper를 2이상으로 설정하기 위한 split-by컬럼을 찾을때 유용하게 활용할 수 있는 쿼리 총관리자 2020.05.13 340
295 Apache Spark와 Drools를 이용한 CEP구현 테스트 총관리자 2016.07.15 342
294 python2.7.4에서 Oracle DB(11.2)를 사용하기 위한 설정(RPM을 이용하여 RHEL 7.4에 설치) 총관리자 2021.11.26 342
293 Hive MetaStore Server기동시 Could not create "increment"/"table" value-generation container SEQUENCE_TABLE since autoCreate flags do not allow it. 오류발생시 조치사항 총관리자 2017.05.03 348
292 [kudu]테이블 drop이 안되고 timeout이 걸리는 경우 조치 방법 총관리자 2020.06.08 348
291 linux에서 특정 포트를 사용하는 프로세스 확인하기 총관리자 2017.04.26 351
290 Ubuntu 16.04 LTS에서 사이트에 무료인증서를 이용하여 SSL적용 file 총관리자 2017.05.23 354
289 impala,hive및 hdfs만 접근가능하고 파일을 이용한 테이블생성가능하도록 hue 권한설정설정 총관리자 2018.09.17 357
288 git설명 한글판 총관리자 2015.12.09 358
287 TransmitData() to failed: Network error: Recv() got EOF from remote (error 108) 오류 현상 총관리자 2019.02.15 359
286 기준일자 이전의 hdfs 데이타를 지우는 shellscript 샘플 총관리자 2019.06.14 359
285 HDFS상의 /tmp폴더에 Permission denied오류가 발생시 조치사항 총관리자 2017.01.25 360
284 root계정으로 MariaDB설치후 mysql -u root -p로 db에 접근하여 바로 해줘야 하는일..(케릭터셑은 utf8) 총관리자 2015.10.02 361
283 hadoop클러스터를 구성하던 서버중 HA를 담당하는 서버의 hostname등이 변경되어 문제가 발생했을때 조치사항 총관리자 2016.07.29 363
282 HUE를 사용할 사용자를 추가 하는 절차 총관리자 2018.05.29 367

A personal place to organize information learned during the development of such Hadoop, Hive, Hbase, Semantic IoT, etc.
We are open to the required minutes. Please send inquiries to gooper@gooper.com.

위로