gc/snp-sync-batch
7
0
포크 0
코드 이슈 풀 리퀘스트 Actions 위키 활동

feat(batch): abandon/stale 실행 관리 엔드포인트 구현 (#7)

소스 검색 
- GET /executions/stale: 장기 실행(stale) 목록 조회
- POST /executions/{id}/abandon: 특정 실행 강제 종료
- POST /executions/stale/abandon-all: stale 일괄 강제 종료
- BatchService에 getStaleExecutions, abandonExecution, abandonAllStale 추가

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
This commit is contained in:
HYOJIN 2026-03-25 08:47:48 +09:00
부모 86f0942194
커밋 cbdc14c3c4
2개의 변경된 파일과 121개의 추가작업 그리고 0개의 파일을 삭제
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

55
src/main/java/com/snp/batch/global/controller/BatchController.java
파일 보기

@ -141,6 +141,61 @@ public class BatchController {
}
}
// ── Stale / Abandon API ────────────────────────────────────
@Operation(summary = "장기 실행(stale) 목록 조회", description = "thresholdMinutes 이상 실행 중인 배치 목록을 조회합니다")
@GetMapping("/executions/stale")
public ResponseEntity<List<JobExecutionDto>> getStaleExecutions(
@RequestParam(defaultValue = "60") int thresholdMinutes) {
List<JobExecutionDto> staleExecutions = batchService.getStaleExecutions(thresholdMinutes);
return ResponseEntity.ok(staleExecutions);
}
@Operation(summary = "실행 강제 종료(abandon)", description = "특정 배치 실행을 강제 종료합니다")
@PostMapping("/executions/{executionId}/abandon")
public ResponseEntity<Map<String, Object>> abandonExecution(@PathVariable Long executionId) {
log.info("Received request to abandon execution: {}", executionId);
try {
batchService.abandonExecution(executionId);
return ResponseEntity.ok(Map.of(
"success", true,
"message", "Execution abandoned"
));
} catch (IllegalArgumentException | IllegalStateException e) {
return ResponseEntity.badRequest().body(Map.of(
"success", false,
"message", e.getMessage()
));
} catch (Exception e) {
log.error("Error abandoning execution: {}", executionId, e);
return ResponseEntity.internalServerError().body(Map.of(
"success", false,
"message", "Failed to abandon execution: " + e.getMessage()
));
}
}
@Operation(summary = "stale 실행 일괄 강제 종료", description = "장기 실행 중인 모든 배치를 일괄 강제 종료합니다")
@PostMapping("/executions/stale/abandon-all")
public ResponseEntity<Map<String, Object>> abandonAllStale(
@RequestParam(defaultValue = "60") int thresholdMinutes) {
log.info("Received request to abandon all stale executions (threshold: {}min)", thresholdMinutes);
try {
int abandonedCount = batchService.abandonAllStale(thresholdMinutes);
return ResponseEntity.ok(Map.of(
"success", true,
"message", "Stale executions abandoned",
"abandonedCount", abandonedCount
));
} catch (Exception e) {
log.error("Error abandoning stale executions", e);
return ResponseEntity.internalServerError().body(Map.of(
"success", false,
"message", "Failed to abandon stale executions: " + e.getMessage()
));
}
}
@Operation(summary = "스케줄 목록 조회", description = "등록된 모든 스케줄을 조회합니다")
@ApiResponses(value = {
@ApiResponse(responseCode = "200", description = "조회 성공")

66
src/main/java/com/snp/batch/service/BatchService.java
파일 보기

@ -113,6 +113,72 @@ public class BatchService {
jobOperator.stop(executionId);
}
/**
* 장기 실행(stale) 목록 조회
* thresholdMinutes 이상 실행 중인(STARTED/STARTING) 실행 목록 반환
*/
public List<JobExecutionDto> getStaleExecutions(int thresholdMinutes) {
java.time.LocalDateTime threshold = java.time.LocalDateTime.now().minusMinutes(thresholdMinutes);
return jobMap.keySet().stream()
.flatMap(jobName -> {
List<JobInstance> instances = jobExplorer.findJobInstancesByJobName(jobName, 0, 10);
return instances.stream()
.flatMap(instance -> jobExplorer.getJobExecutions(instance).stream());
})
.filter(exec -> exec.isRunning())
.filter(exec -> exec.getStartTime() != null && exec.getStartTime().isBefore(threshold))
.sorted(Comparator.comparing(JobExecution::getStartTime))
.map(this::convertToDto)
.collect(Collectors.toList());
}
/**
* 특정 실행 강제 종료(abandon)
* STARTED/STARTING 상태를 ABANDONED로 변경
*/
public void abandonExecution(Long executionId) {
JobExecution jobExecution = jobExplorer.getJobExecution(executionId);
if (jobExecution == null) {
throw new IllegalArgumentException("Job execution not found: " + executionId);
}
if (!jobExecution.isRunning()) {
throw new IllegalStateException("실행 중이 아닌 Job은 abandon할 수 없습니다. 현재 상태: " + jobExecution.getStatus());
}
jobExecution.setStatus(org.springframework.batch.core.BatchStatus.ABANDONED);
jobExecution.setEndTime(java.time.LocalDateTime.now());
jobExecution.setExitStatus(new org.springframework.batch.core.ExitStatus("ABANDONED", "수동 강제 종료"));
jobExplorer.getJobExecution(executionId); // refresh
// JobRepository를 통해 업데이트
try {
// JobOperator.abandon()은 STARTED가 아닌 STOPPING 상태에서만 동작하므로 직접 업데이트
jobOperator.stop(executionId);
} catch (Exception e) {
log.warn("stop 호출 실패 (이미 종료됨): {}", e.getMessage());
}
log.info("Execution {} abandoned", executionId);
}
/**
* stale 실행 일괄 강제 종료
*/
public int abandonAllStale(int thresholdMinutes) {
List<JobExecutionDto> staleExecutions = getStaleExecutions(thresholdMinutes);
int count = 0;
for (JobExecutionDto exec : staleExecutions) {
try {
abandonExecution(exec.getExecutionId());
count++;
} catch (Exception e) {
log.warn("Abandon 실패 - executionId: {}, error: {}", exec.getExecutionId(), e.getMessage());
}
}
log.info("Stale executions abandoned: {}/{}", count, staleExecutions.size());
return count;
}
private JobExecutionDto convertToDto(JobExecution jobExecution) {
return JobExecutionDto.builder()