Package com.poscoict.app.job

Class GlueJobStatusCheck

java.lang.Object
com.poscoict.app.job.GlueJobStatusCheck
Direct Known Subclasses:
PoscoJobStatusCheck
public abstract class GlueJobStatusCheck extends Object
Job 실행여부 확인 Util. 
 사용예#1
 
 String JobKey = ... ;//sample1.job001
 GlueJobDefinition jobDefinition = ...; //new GlueJobDefinition( "-1", JobKey );
 String serverAddress = ...; //http://192.168.41.141:8805
 GlueJobEventSender sender = ...;// GlueStaticContext.getBeanFactory().getBeanObject( "jobEventSender", GlueJobEventSender.class );
 String historyId = sender.sendJobEvent( def, serverAddress + "/scheduler" );

 String status = GlueJobStatusCheck.getJobStatus(serverAddress, historyId, JobKey );
 


 사용예#2
 
 String JobKey = ... ;//sample1.job001
 String serverAddress = ...; //http://192.168.41.141:8805
 String ids = GlueJobStatusCheck.getJobHistoryIdsByJobKey(serverAddress, JobKey );
 String[] historyIds = ids.split( "," );
 for( String historyId : historyIds ){
     String status = GlueJobStatusCheck.getJobStatus(serverAddress, historyId, JobKey );
 }
See Also:
  • CloseableHttpClient
  • HttpPost

  • Constructor Details

    • GlueJobStatusCheck

      public GlueJobStatusCheck()

  • Method Details

    • getJobStatus

      public static String getJobStatus(String url, String requestId, String jobKey)
      Parameters:
      url - GlueJobScheduler Server 주소. 내부적으로 HttpClient 를 통해 PostMethod 실행 URL임
      requestId - Job History ID. 내부적으로 NameValuePair 으로 생성되서 setRequestBody()로 전달됨.
      jobKey - JobKey. 내부적으로 NameValuePair 으로 생성되서 setRequestBody()로 전달됨. requestId 가 유효한지 체크하는데 사용됨.
      Returns:
      COMPLETE, STOPPED, ERROR, MISFIRED, RUNNING 등의 STATUS 값.

    • getJobStatus

      public static String getJobStatus(String url, String requestId, String jobKey, String ip)
      Parameters:
      url - GlueJobScheduler Server 주소. 내부적으로 HttpClient 를 통해 PostMethod 실행 URL임.
      requestId - Job History ID. 내부적으로 NameValuePair 으로 생성되서 setRequestBody()로 전달됨.
      jobKey - JobKey. 내부적으로 NameValuePair 으로 생성되서 setRequestBody()로 전달됨. requestId 가 유효한지 체크하는데 사용됨.
      ip - LocalHost 주소. 내부적으로 NameValuePair 으로 생성되서 setRequestBody()로 전달됨.
      Returns:
      COMPLETE, STOPPED, ERROR, MISFIRED, RUNNING 등의 STATUS 값.

    • getJobStatus

      public static String getJobStatus(String url, String requestId, String jobKey, String ip, int retryCount)
      Parameters:
      url - GlueJobScheduler Server 주소. 내부적으로 HttpClient 를 통해 PostMethod 실행 URL임.
      requestId - Job History ID. 내부적으로 NameValuePair 으로 생성되서 setRequestBody()로 전달됨.
      jobKey - JobKey. 내부적으로 NameValuePair 으로 생성되서 setRequestBody()로 전달됨. requestId 가 유효한지 체크하는데 사용됨.
      ip - LocalHost 주소. 내부적으로 NameValuePair 으로 생성되서 setRequestBody()로 전달됨.
      retryCount - HttpClient 를 통해 PostMethod 실행 실패시 재시도 횟수임.
      Returns:
      COMPLETE, STOPPED, ERROR, MISFIRED, RUNNING 등의 STATUS 값.

    • getJobHistoryIdsByJobKey

      public static String getJobHistoryIdsByJobKey(String url, String jobKey)
      Parameters:
      url - GlueJobScheduler Server 주소. 내부적으로 HttpClient 를 통해 PostMethod 실행 URL임.
      jobKey - JobKey. 내부적으로 NameValuePair 으로 생성되서 setRequestBody()로 전달됨.
      Returns:
      실행중이거나 대기중인 Job Histroy ID. 2개 이상일경우 컴마(,)로 구분함.

    • getJobHistoryIdsByJobKey

      public static String getJobHistoryIdsByJobKey(String url, String jobKey, String ip)
      Parameters:
      url - GlueJobScheduler Server 주소. 내부적으로 HttpClient 를 통해 PostMethod 실행 URL임.
      jobKey - JobKey. 내부적으로 NameValuePair 으로 생성되서 setRequestBody()로 전달됨.
      ip - LocalHost 주소. 내부적으로 NameValuePair 으로 생성되서 setRequestBody()로 전달됨.
      Returns:
      실행중이거나 대기중인 Job Histroy ID. 2개 이상일경우 컴마(,)로 구분함.

    • getJobHistoryIdsByJobKey

      public static String getJobHistoryIdsByJobKey(String url, String jobKey, String ip, int retryCount)
      Parameters:
      url - GlueJobScheduler Server 주소. 내부적으로 HttpClient 를 통해 PostMethod 실행 URL임.
      jobKey - JobKey. 내부적으로 NameValuePair 으로 생성되서 setRequestBody()로 전달됨.
      ip - LocalHost 주소. 내부적으로 NameValuePair 으로 생성되서 setRequestBody()로 전달됨.
      retryCount - HttpClient 를 통해 PostMethod 실행 실패시 재시도 횟수임.
      Returns:
      실행중이거나 대기중인 Job Histroy ID. 2개 이상일경우 컴마(,)로 구분함.