[스프링] Oozie 워크플로우에서의 시간 기반 작업 스케줄링

22 Dec 2023

스프링

스프링과 Oozie를 사용하여 시간 기반의 작업을 스케줄링하는 것은 매우 유용합니다. Oozie 워크플로우를 사용하면 워크플로우의 여러 작업들을 시간에 따라 조정할 수 있으며, 스프링을 통해 각 작업을 실행하여 효과적으로 자원을 관리할 수 있습니다. 이 글에서는 이러한 시간 기반 작업 스케줄링을 구현하는 방법을 소개하겠습니다.

시간 기반 작업 스케줄링 구성

Oozie 워크플로우 정의

Oozie를 사용하여 시간 기반 작업을 스케줄링하려면 먼저 워크플로우를 정의해야 합니다. 이를 통해 작업들 간의 의존성과 실행 시간 등을 설정할 수 있습니다.

<workflow-app name="my_workflow" xmlns="uri:oozie:workflow:0.5">
    <start to="some_action" />
    <action name="some_action">
        ...
        <ok to="end" />
        <error to="fail" />
    </action>
    <kill name="fail">
        <message>Workflow failed, error message[${wf:errorMessage(wf:lastErrorNode())}]</message>
    </kill>
    <end name="end" />
</workflow-app>

스프링을 이용한 작업 실행

스프링 프레임워크를 사용하여 Oozie 워크플로우 내의 각 작업을 실행합니다. 각 작업은 스프링 빈으로 정의되어야 하며, 필요한 작업 파라미터 등을 주입하여 실행합니다.

@Service
public class MySpringService {
    
    @Autowired
    private MyJobScheduler myJobScheduler;
    
    public void performTask() {
        myJobScheduler.scheduleTask();
    }
}

public class MyJobScheduler {
    
    public void scheduleTask() {
        // 작업 스케줄링 작업 수행
    }
}

시간 기반 작업 스케줄링 실행

Oozie 워크플로우 실행 명령

Oozie CLI를 사용하여 워크플로우를 실행합니다. 실행 명령에는 실행할 워크플로우의 경로와 실행에 필요한 다양한 파라미터를 포함할 수 있습니다.

oozie job -config job.properties -run

스프링 작업 실행

Oozie 워크플로우 내에서 정의된 각 작업은 스프링을 통해 실행됩니다. 스프링이 제공하는 스케줄링 기능을 사용하여 작업을 수행하고 완료합니다.

@Service
public class MyJobScheduler {
    
    @Scheduled(cron = "0 0 12 * * ?")
    public void scheduleTask() {
        // 매일 정오에 실행되는 작업
        // 실제 작업 수행
    }
}

이렇게하면 시간 기반의 작업 스케줄링을 스프링과 Oozie를 통해 구현할 수 있습니다.

이상으로 스프링과 Oozie를 이용한 시간 기반 작업 스케줄링에 대해 알아보았습니다. 다양한 기능을 조합하여 효율적인 작업 스케줄링을 구현할 수 있으며, 이를 통해 업무 효율성을 향상시킬 수 있습니다.

참고 문헌:

Oozie 워크플로우 문서: Oozie Documentation
스프링 스케줄링: Spring Scheduling