메뉴 건너뛰기

검색창 닫기

Cloudera, BigData, Semantic IoT, Hadoop, NoSQL

Cloudera CDH/CDP 및 Hadoop EcoSystem, Semantic IoT등의 개발/운영 기술을 정리합니다. gooper@gooper.com로 문의 주세요.


Drools 실시간 쿼리 변환 모니터링(팩트내 필드값의 변경사항을 실시간으로 추적함)하는 테스트 java 프로그램

총관리자 2016.07.21 17:42 조회 수 : 148

---------실행결과-------------
[2016-07-21 17:38:27] [CustomWorkingMemoryEventListener] [23] [INFO] Object Inserted : [fact 0:1:888473870:888473870:1:DEFAULT:Server [name=winServer, processors=4, memory=4096, diskSpace=2048, cpuUsage=25, getName()=winServer, getProcessors()=4, getMemory()=4096, getDiskSpace()=2048, getCpuUsage()=25, getClass()=class com.gooper.drool_test.ServerInfo, hashCode()=888473870, toString()=com.gooper.drool_test.ServerInfo@34f5090e]] Knowledge Runtime: org.drools.core.impl.StatefulKnowledgeSessionImpl@614ca7df 
[2016-07-21 17:38:27] [CustomWorkingMemoryEventListener] [23] [INFO] Object Inserted : [fact 0:2:416841088:416841088:2:DEFAULT:Server [name=ubuntuServer, processors=4, memory=2048, diskSpace=1024, cpuUsage=70, getName()=ubuntuServer, getProcessors()=4, getMemory()=2048, getDiskSpace()=1024, getCpuUsage()=70, getClass()=class com.gooper.drool_test.ServerInfo, hashCode()=416841088, toString()=com.gooper.drool_test.ServerInfo@18d87d80]] Knowledge Runtime: org.drools.core.impl.StatefulKnowledgeSessionImpl@614ca7df 
[2016-07-21 17:38:27] [CustomWorkingMemoryEventListener] [23] [INFO] Object Inserted : [fact 0:3:1412794598:1412794598:3:DEFAULT:Server [name=debianServer, processors=4, memory=2048, diskSpace=1024, cpuUsage=10, getName()=debianServer, getProcessors()=4, getMemory()=2048, getDiskSpace()=1024, getCpuUsage()=10, getClass()=class com.gooper.drool_test.ServerInfo, hashCode()=1412794598, toString()=com.gooper.drool_test.ServerInfo@543588e6]] Knowledge Runtime: org.drools.core.impl.StatefulKnowledgeSessionImpl@614ca7df 
 session.getFactCount() = 3
[2016-07-21 17:38:27] [CustomAgendaEventListener] [133] [INFO] Match Created : [fact 0:2:416841088:416841088:2:DEFAULT:Server [name=ubuntuServer, processors=4, memory=2048, diskSpace=1024, cpuUsage=70, getName()=ubuntuServer, getProcessors()=4, getMemory()=2048, getDiskSpace()=1024, getCpuUsage()=70, getClass()=class com.gooper.drool_test.ServerInfo, hashCode()=416841088, toString()=com.gooper.drool_test.ServerInfo@18d87d80]] 
[2016-07-21 17:38:27] [CustomAgendaEventListener] [133] [INFO] Match Created : [fact 0:1:888473870:888473870:1:DEFAULT:Server [name=winServer, processors=4, memory=4096, diskSpace=2048, cpuUsage=25, getName()=winServer, getProcessors()=4, getMemory()=4096, getDiskSpace()=2048, getCpuUsage()=25, getClass()=class com.gooper.drool_test.ServerInfo, hashCode()=888473870, toString()=com.gooper.drool_test.ServerInfo@34f5090e]] 
[2016-07-21 17:38:27] [CustomAgendaEventListener] [113] [INFO] Before Match Fired : [fact 0:2:416841088:416841088:2:DEFAULT:Server [name=ubuntuServer, processors=4, memory=2048, diskSpace=1024, cpuUsage=70, getName()=ubuntuServer, getProcessors()=4, getMemory()=2048, getDiskSpace()=1024, getCpuUsage()=70, getClass()=class com.gooper.drool_test.ServerInfo, hashCode()=416841088, toString()=com.gooper.drool_test.ServerInfo@18d87d80]] 
[2016-07-21 17:38:27] [check minimum server configuration2] [20] [INFO] Server "ubuntuServer" was rejected... 
[2016-07-21 17:38:27] [CustomWorkingMemoryEventListener] [18] [INFO] Object Deleted : [fact 0:2:416841088:416841088:2:DEFAULT:Server [name=ubuntuServer, processors=4, memory=2048, diskSpace=1024, cpuUsage=70, getName()=ubuntuServer, getProcessors()=4, getMemory()=2048, getDiskSpace()=1024, getCpuUsage()=70, getClass()=class com.gooper.drool_test.ServerInfo, hashCode()=416841088, toString()=com.gooper.drool_test.ServerInfo@18d87d80]] Knowledge Runtime: org.drools.core.impl.StatefulKnowledgeSessionImpl@614ca7df 
[2016-07-21 17:38:27] [CustomAgendaEventListener] [76] [DEBUG] Rule fired: check minimum server configuration2 
[2016-07-21 17:38:27] [CustomAgendaEventListener] [113] [INFO] Before Match Fired : [fact 0:1:888473870:888473870:1:DEFAULT:Server [name=winServer, processors=4, memory=4096, diskSpace=2048, cpuUsage=25, getName()=winServer, getProcessors()=4, getMemory()=4096, getDiskSpace()=2048, getCpuUsage()=25, getClass()=class com.gooper.drool_test.ServerInfo, hashCode()=888473870, toString()=com.gooper.drool_test.ServerInfo@34f5090e]] 
[2016-07-21 17:38:27] [check minimum server configuration2] [20] [INFO] Server "winServer" was rejected... 
[2016-07-21 17:38:27] [CustomWorkingMemoryEventListener] [18] [INFO] Object Deleted : [fact 0:1:888473870:888473870:1:DEFAULT:Server [name=winServer, processors=4, memory=4096, diskSpace=2048, cpuUsage=25, getName()=winServer, getProcessors()=4, getMemory()=4096, getDiskSpace()=2048, getCpuUsage()=25, getClass()=class com.gooper.drool_test.ServerInfo, hashCode()=888473870, toString()=com.gooper.drool_test.ServerInfo@34f5090e]] Knowledge Runtime: org.drools.core.impl.StatefulKnowledgeSessionImpl@614ca7df 
[2016-07-21 17:38:27] [CustomAgendaEventListener] [76] [DEBUG] Rule fired: check minimum server configuration2 
 matched count of Fact = 2
listener.getCurrentServers().size() : 1
[2016-07-21 17:38:27] [CustomWorkingMemoryEventListener] [29] [INFO] Object Updated : [fact 0:2:416841088:416841088:5:DEFAULT:Server [name=ubuntuServer, processors=4, memory=2048, diskSpace=1024, cpuUsage=10, getName()=ubuntuServer, getProcessors()=4, getMemory()=2048, getDiskSpace()=1024, getCpuUsage()=10, getClass()=class com.gooper.drool_test.ServerInfo, hashCode()=416841088, toString()=com.gooper.drool_test.ServerInfo@18d87d80]] Knowledge Runtime: org.drools.core.impl.StatefulKnowledgeSessionImpl@614ca7df 
listener.getCurrentServers().size() : 1
[2016-07-21 17:38:27] [CustomWorkingMemoryEventListener] [29] [INFO] Object Updated : [fact 0:2:416841088:416841088:6:DEFAULT:Server [name=ubuntuServer, processors=4, memory=2048, diskSpace=1024, cpuUsage=5, getName()=ubuntuServer, getProcessors()=4, getMemory()=2048, getDiskSpace()=1024, getCpuUsage()=5, getClass()=class com.gooper.drool_test.ServerInfo, hashCode()=416841088, toString()=com.gooper.drool_test.ServerInfo@18d87d80]] Knowledge Runtime: org.drools.core.impl.StatefulKnowledgeSessionImpl@614ca7df 
listener.getCurrentServers().size() : 1
listener.getCurrentServers().size() : 1
 session.getObject(ubuntuServerFactHandle) : null
ubuntuServerFactHandle : 0:2:416841088:416841088:6:DEFAULT


------------------------------DroolsTest2.java----------------
package com.gooper.drool_test;

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

import com.gooper.drool_test.CustomWorkingMemoryEventListener;
import com.gooper.drool_test.CustomAgendaEventListener;

/* 실시간 쿼리 변환 모니터링
 * 팩트내의 필드값이 변경될때 실시간으로 변화를 추적함
 */
public class DroolsTest2 {

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

              // 지식 빌더 생성
                    KnowledgeBuilder kbuilder = KnowledgeBuilderFactory.newKnowledgeBuilder();
                    
                    // 지식 빌더에 룰정의파일 설정
                    kbuilder.add(ResourceFactory. newClassPathResource("server_rule.drl"), ResourceType. DRL );

if (kbuilder.hasErrors()) {
if(kbuilder.getErrors().size() > 0) {
for(KnowledgeBuilderError kerror : kbuilder.getErrors()) {
System.out.println("error :" + kerror);
}
}
}
// 새로운 지식 베이스 생성
                    KieBase kiebase = kbuilder.newKnowledgeBase();
                    
                    // 새로운 지식 베이스 세션 생성
                    KieSession session = kiebase.newKieSession();
                    
                    // logger등록(팩트에 의해 생성된 엑티베이션(Activation)관련 이벤트만 로깅)
                    session.addEventListener(new CustomAgendaEventListener());
                    
                    // logger등록(팩트의 추가/수정/제거 이벤트에 대한 정보)
                    session.addEventListener(new CustomWorkingMemoryEventListener());
                    
                    // 지식 베이스의 getFactType 메서드를 이용하여 동적으로 팩트를 인스턴스화 시킨다.
                    // (팩트가 선언되어 있는 룰의 패키지 이름과 팩트의 이름을 인자로 받는다.) 
                    
                    //winServer 생성
                    ServerInfo winServer = new ServerInfo("winServer", 4, 4096, 2048, 25);
                    //winServer등록
                    session.insert(winServer);
                    
                    //ubuntuServer생성
                    ServerInfo ubuntuServer = new ServerInfo("ubuntuServer", 4, 2048, 1024, 70);
                    //ubuntuServer등록
                    FactHandle ubuntuServerFactHandle = session.insert(ubuntuServer);
                    
                    //debianServer생성
                    ServerInfo debianServer = new ServerInfo("debianServer", 4, 2048, 1024, 10);
                    //debianServer등록
                    session.insert(debianServer);
                    
                    System.out.println(" session.getFactCount() = " + session.getFactCount());
                    
                    int matchedCnt = session.fireAllRules();
                    System.out.println(" matched count of Fact = " + matchedCnt);
                    
                    //System.out.println(" session.getProcessInstances() : " + session.getProcessInstances());
                    
                    
                    // 쿼리를 모니터링하는데 사용하는 리스너
                    CustomViewChangedEventListener listener = new CustomViewChangedEventListener();
                    
                    // 모니터링 대상 쿼리이름, 쿼리에 필요한 파라미터, 쿼리를 모니터링하는데 사용하는 리스너
                    LiveQuery query = session.openLiveQuery("serverCpuUsage",  new Object[]{20},  listener);
                    
                    
                    // query results에 단지 1개의 서버 오브젝트만 있음
                    System.out.println("listener.getCurrentServers().size() : " + listener.getCurrentServers().size());
                    
                    ubuntuServer.setCpuUsage(10);
                    session.update(ubuntuServerFactHandle,  ubuntuServer);
                    
                    // query resutls에 2개의 서버 오브젝트가 있음
                    System.out.println("listener.getCurrentServers().size() : " +  listener.getCurrentServers().size());
                    
                    ubuntuServer.setCpuUsage(5);
                    session.update(ubuntuServerFactHandle,  ubuntuServer);
                    
                    // 2 server objects still in the query results
                    System.out.println("listener.getCurrentServers().size() : " + listener.getCurrentServers().size());
                    
                    // but one of them was updated
                    System.out.println("listener.getCurrentServers().size() : " + listener.getCurrentServers().size());
                   
                    //FactHandle로 내용확인하기
                    System.out.println(" session.getObject(ubuntuServerFactHandle) : " + session.getObject(ubuntuServerFactHandle));
                    
                    
                   // System.out.println(" session.getProcessInstances() : " + session.getProcessInstances());
                    
                    
                    query.close();

                    session.dispose();
                    
                    // match된 fact를 확인함
                    System.out.println("ubuntuServerFactHandle : "+ubuntuServerFactHandle.toExternalForm());


              } catch (Throwable t) {
                     t.printStackTrace();
              }
       }
}
이 게시물을
이 글의 추천인 목록 목록
번호 제목 날짜 조회 수
61 외부 jar파일을 만들려고하는jar파일의 package로 포함하는 방법 2016.08.10 152
60 Cloudera의 CMS각 컴포넌트의 역할 2020.02.10 151
59 Core with name 'xx_shard4_replica1' already exists. 발생시 조치사항 2017.07.22 151
58 ServerInfo객체파일 2016.07.21 150
57 [KTS Cluster의 Key Trustee Server]self-signed 인증서 발급및 설정 방법 2023.06.27 149
56 [Kerberos인증] /var/log/krb5kdc.log파일 기준으로 인증요청(AS), 티켓확인(TGS)이 진행되는 로그 기록 2022.09.21 149
55 LAGOM 1.4 AND KUBERNETES ORCHESTRATION 2019.07.19 149
» 실시간 쿼리 변환 모니터링(팩트내 필드값의 변경사항을 실시간으로 추적함)하는 테스트 java 프로그램 file 2016.07.21 148
53 Master rejected startup because clock is out of sync 오류 해결방법 2016.05.03 148
52 windows10 pro에서 microservice pattern책의 예제를 kubernetes에서 기동하는 방법 2022.01.30 147
51 magento2 log파일 위치 2017.01.31 145
50 Github를 이용하는 전체 흐름 이해하기 2016.11.18 145
49 "암은 평범한 병, 심호흡만 잘해도 암세포 분열 저지” 2016.06.02 143
48 [CDP7.1.7]Hive Replication수행시 Target Cluster에서 Specified catalog.database.table does not exist 오류 2024.05.08 142
47 windows 혹은 mac에서 docker설치하기 위한 파일 2017.10.13 142
46 9대가 hbase cluster로 구성된 서버에서 테스트 data를 halyard에 적재하고 테스트 하는 방법및 절차 2017.07.21 142
45 [Oracle 11g]Kudu table의 meta정보를 담고 있는 table_params의 백업본을 이용하여 특정 컬럼값을 update하는 Oracle SQL문 2023.09.04 141
44 Hadoop Clsuter에 이미 포함된 host의 hostname변경시 처리 절차 2023.03.24 141
43 DataSetCreator.py 실행시 파일을 찾을 수 없는 오류 2016.05.27 141
42 [u-Auctions]목록이 1개만 나오는 문제 2017.05.29 137
쓰기 태그
위로