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

fix: L2 워밍업 범위 확장 — Daily Job 전 기동 시 어제 데이터 포함

소스 검색 
00:00~01:00 기동: 어제 00:00 ~ 현재 정각 (Daily Job용)
01:00 이후 기동: 오늘 00:00 ~ 현재 정각 (기존 동작)

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
This commit is contained in:
htlee 2026-02-21 00:42:28 +09:00
부모 7681fc6031
커밋 3250da7347
1개의 변경된 파일과 15개의 추가작업 그리고 10개의 파일을 삭제
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
src/main/java/gc/mda/signal_batch/global/config/CacheWarmupService.java
파일 보기

@ -68,6 +68,10 @@ public class CacheWarmupService {
LocalDateTime currentHour = now.withMinute(0).withSecond(0).withNano(0);
LocalDateTime todayStart = now.toLocalDate().atStartOfDay();
// Daily Job(01:00) 이전 기동 시 어제 데이터도 L2에 필요
boolean beforeDailyJob = now.getHour() < 1;
LocalDateTime l2Start_time = beforeDailyJob ? todayStart.minusDays(1) : todayStart;
// 1. L1 워밍업: 현재 시간대 5min 트랙 (예: 12:00~12:50)
long l1Start = System.currentTimeMillis();
try {
@ -77,10 +81,10 @@ public class CacheWarmupService {
}
long l1Elapsed = System.currentTimeMillis() - l1Start;
// 2. L2 워밍업: 오늘 정각 이전 hourly 트랙 (예: 00:00~12:00)
// 2. L2 워밍업: 00:00~01:00 기동 시 어제+오늘, 이후는 오늘만
long l2Start = System.currentTimeMillis();
try {
warmUpHourlyCache(todayStart, currentHour);
warmUpHourlyCache(l2Start_time, currentHour);
} catch (Exception e) {
log.error("[CACHE-MONITOR] L2(hourly) 워밍업 실패 — 계속 진행: {}", e.getMessage());
}
@ -123,12 +127,13 @@ public class CacheWarmupService {
}
/**
* L2 워밍업: t_vessel_tracks_hourly에서 오늘 정각 이전 DB 로드
* 예: 12:54 기동 → 00:00~12:00 (최대 12건/MMSI) 로드
* L2 워밍업: t_vessel_tracks_hourly에서 DB 로드
* - 01:00 이후 기동: 오늘 00:00 ~ 현재 정각 (최대 24건/MMSI)
* - 00:00~01:00 기동: 어제 00:00 ~ 현재 정각 (Daily Job용 어제 데이터 포함)
*/
private void warmUpHourlyCache(LocalDateTime todayStart, LocalDateTime currentHour) {
if (!currentHour.isAfter(todayStart)) {
log.info("[CACHE-MONITOR] L2 워밍업: 자정 직후 — 건너뜀");
private void warmUpHourlyCache(LocalDateTime rangeStart, LocalDateTime currentHour) {
if (!currentHour.isAfter(rangeStart)) {
log.info("[CACHE-MONITOR] L2 워밍업: 범위 없음 [{}, {}) — 건너뜀", rangeStart, currentHour);
return;
}
@ -138,15 +143,15 @@ public class CacheWarmupService {
"FROM signal.t_vessel_tracks_hourly " +
"WHERE time_bucket >= ? AND time_bucket < ?";
List<VesselTrack> tracks = loadVesselTracksFromDb(sql, todayStart, currentHour);
List<VesselTrack> tracks = loadVesselTracksFromDb(sql, rangeStart, currentHour);
if (!tracks.isEmpty()) {
long distinctMmsi = tracks.stream().map(VesselTrack::getMmsi).distinct().count();
hourlyTrackCache.putAll(tracks);
log.info("[CACHE-MONITOR] L2 워밍업 완료: [{}, {}) → {} 건, {} MMSI, cacheSize={}",
todayStart, currentHour, tracks.size(), distinctMmsi, hourlyTrackCache.size());
rangeStart, currentHour, tracks.size(), distinctMmsi, hourlyTrackCache.size());
} else {
log.info("[CACHE-MONITOR] L2 워밍업: [{}, {}) → 데이터 없음 (정상)",
todayStart, currentHour);
rangeStart, currentHour);
}
}