CONFETI-77 feat: TopArtist 갱신을 위한 배치 작업 구현 #9

gwagjiug · 2026-01-02T16:38:29Z

🔊 Summaries

TopArtist 갱신을 위한 스케줄러 구현
매일 새벽 5시에 Apple Music Charts API에서 인기곡 200개를 조회하여 아티스트 순위 갱신
주요 변경사항:
- TopArtistSyncSchedule: 스케줄러 메인 로직
- TopArtistService: DB 갱신 로직 (기존 데이터 삭제 후 새로 저장)
- AppleMusicFeignClient: /charts API 엔드포인트 추가
- MusicAPIHandler: getTopSongs(), getSongsByIds() 메서드 추가
- Charts API 응답용 DTO 추가 (AppleMusicChartsResponse 등)

✨ Notification

스케줄러 활성화를 위해 DB job_config 테이블에 TOP_ARTIST_SYNC 레코드 추가 필요
INSERT INTO job_config (job_info, is_active, description)
VALUES ('TOP_ARTIST_SYNC', true, 'TopArtist 동기화');
스케줄 시간: 매일 05:00 (Asia/Seoul)

gwagjiug · 2026-01-02T16:40:14Z

src/main/java/confeti/confetibatchserver/domain/music/topartist/TopArtist.java

-    @JoinColumn(name = "artist_id", unique = true)
+    @Column(name = "artist_id", nullable = false, unique = true)


JoinColumn 이어야 하는 이유가 있었나요? 단순 문자열 저장이라 어노테이션 수정했어요

비즈니스 로직이 아니라 연관 관계 정보를 조회할 일이 없어서 Column으로 해도 무방할거 같긴해요
나중에 필요하면 바꿔서 패치 조인을 사용해도 되고, 사실 jdbc를 쓰고 있으니까 그냥 쿼리로 땡겨와도 될거 같네요

gwagjiug · 2026-01-02T16:43:03Z

...ain/java/confeti/confetibatchserver/domain/music/topartist/application/TopArtistService.java

+
+    private final TopArtistRepository topArtistRepository;
+
+    @Transactional


트랜잭션 설정해두었어요. 기존 데이터 삭제하고 DB에 삽입해요

gwagjiug · 2026-01-02T16:49:14Z

...main/java/confeti/confetibatchserver/external/client/dto/chart/AppleMusicChartsResponse.java

+package confeti.confetibatchserver.external.client.dto.chart;
+
+public record AppleMusicChartsResponse(
+    AppleMusicChartResponse results
+) {
+
+}


근데 Apple Music 은 왜 API 응답을 이렇게 복잡하게 내려주는거예요? 그리고 일단 기존 패턴이 Json 필드 하나 하나를 분리하고 있길래 일치시키긴했는데, 왜 이렇게 하는거예요? 애플 뮤직 응답의 경우 한 파일에 두어도 되지않나 싶었는데 일단 잘몰라서 하는 소리입니다~ just wonder

아 원래 한 파일에 두는게 베스트인데 그땐 제가 잘 몰라서 분리했었어요.
애플 뮤직 api 응답 스펙에 맞추다보니 파일이 많아진거 같아요
아마 도메인 별로, 예를 들어서 아티스트, 음악 등으로 나눠서 한 파일에 구조를 저장하면 복잡하지 않을 것 같네요
좋은 의견입니다 👍🏻

gwagjiug · 2026-01-02T16:55:44Z

src/main/java/confeti/confetibatchserver/external/client/dto/music/AppleMusicMusicResponse.java

+    public List<String> getArtistIds() {
+        return Optional.ofNullable(relationships())
+            .map(AppleMusicMusicRelationshipsResponse::artists)
+            .map(AppleMusicMusicArtistsResponse::data)
+            .map(data -> data.stream()
+                .map(AppleMusicMusicArtistResponse::id)
+                .toList())
+            .orElse(Collections.emptyList());
+    }


얘가 제일 헷갈렸어요. 코드가 좀 절차적인 것 같기도하고.. 로직한번 봐주세요

좋은데요??

저도 좋은거 같아요 더 깔끔하게 하고 싶으면 AppleMusicMusicArtistsResponse 내에 List 을 반환하는 메서드 getArtistIds 같은걸 두고 .map(AppleMusicMusicArtistsResponse::getArtistIds) 처럼 두는 것도 가능할 것 같긴 한데 지금도 좋네요

ch1hyun

ㅋㅋㅋㅋ 잘했네
고생했습니다~~

ch1hyun · 2026-01-03T02:05:49Z

src/main/java/confeti/confetibatchserver/external/service/AppleMusicAPIHandler.java

+        return Optional.ofNullable(chartsResponse.results())
+            .map(results -> results.songs())
+            .filter(songs -> !songs.isEmpty())
+            .map(songs -> songs.get(0))
+            .map(AppleMusicChartSongResponse::data)
+            .orElse(Collections.emptyList());


별건 아닌데 이렇게 수정하면 더욱 깔끔해보일 것 같아요

Suggested change

return Optional.ofNullable(chartsResponse.results())

.map(results -> results.songs())

.filter(songs -> !songs.isEmpty())

.map(songs -> songs.get(0))

.map(AppleMusicChartSongResponse::data)

.orElse(Collections.emptyList());

.map(AppleMusicChartResponse::songs)

.filter(songs -> !songs.isEmpty())

.map(List::getFirst)

.map(AppleMusicChartSongResponse::data)

.orElse(Collections.emptyList());

jher235

좋은데요...? 작업 속도도 매우 빠르고 컨텍스트 스위칭 비용이 별로 안드시네요 👍 훌륭합니다..

jher235 · 2026-01-03T03:23:17Z

...ain/java/confeti/confetibatchserver/domain/music/topartist/application/TopArtistService.java

+    @Transactional
+    public void refresh(List<String> artistIds) {
+        topArtistRepository.deleteAllInBatch();
+
+        List<TopArtist> topArtists = IntStream.range(0, artistIds.size())
+            .mapToObj(idx -> TopArtist.create(artistIds.get(idx), idx + 1))
+            .toList();
+
+        topArtistRepository.saveAll(topArtists);
+    }


사소한 이슈고 지금 코드도 좋아서 굳이 반영할 필욘 없는데 saveAll() 은 사실 내부적으로 반복문을 돌면서 upsert를 하는 메서드여서 TopArtist 개수 만큼의 쿼리가 발생해요. 벌크 쿼리를 사용한다면 좀 더 효율적일 수 있겠네요.

음 좋은 관점이네용 일단 얘는 유지해볼게요

jher235 · 2026-01-03T03:36:19Z

src/main/java/confeti/confetibatchserver/external/client/dto/music/AppleMusicMusicResponse.java

+    public List<String> getArtistIds() {
+        return Optional.ofNullable(relationships())
+            .map(AppleMusicMusicRelationshipsResponse::artists)
+            .map(AppleMusicMusicArtistsResponse::data)
+            .map(data -> data.stream()
+                .map(AppleMusicMusicArtistResponse::id)
+                .toList())
+            .orElse(Collections.emptyList());
+    }


저도 좋은거 같아요 더 깔끔하게 하고 싶으면 AppleMusicMusicArtistsResponse 내에 List 을 반환하는 메서드 getArtistIds 같은걸 두고 .map(AppleMusicMusicArtistsResponse::getArtistIds) 처럼 두는 것도 가능할 것 같긴 한데 지금도 좋네요

jher235 · 2026-01-03T03:43:02Z

src/main/java/confeti/confetibatchserver/scheduler/TopArtistSyncSchedule.java

+            List<AppleMusicMusicResponse> topSongs = musicAPIHandler.getTopSongs(TOP_SONGS_FETCH_SIZE);
+
+            Set<String> songIds = topSongs.stream()
+                .map(AppleMusicMusicResponse::id)
+                .collect(Collectors.toCollection(LinkedHashSet::new));
+
+            List<AppleMusicMusicResponse> songsWithArtists = musicAPIHandler.getSongsByIds(songIds);


아마 이 부분을 Confeti Api Server 에서 가져오셔서 이렇게 한 것 같은데 사실 저희는 지금 배치 서버다 보니까 List topSongs 가 distinct 하다는게 사실상 보장되잖아요? 그래서 굳이 Set으로 변환하지 않고 호출하는 것도 괜찮을 것 같아요. musicAPIHandler.getSongsByIds() 의 파라미터가 Set타입이라면 Collection 으로 변경하고 여기서 Set 변환 없이 그냥 List로 전달하는건 어떨까요?

이거 놓쳤네용 좋은 것 같아요 반영해둘게요

List<String> songIds = topSongs.stream() .map(AppleMusicMusicResponse::id) .toList(); List<AppleMusicMusicResponse> songsWithArtists = musicAPIHandler.getSongsByIds(songIds);

jher235 · 2026-01-03T03:46:37Z

src/main/java/confeti/confetibatchserver/scheduler/TopArtistSyncSchedule.java

+            List<String> artistIds = songsWithArtists.stream()
+                .flatMap(song -> song.getArtistIds().stream())
+                .collect(Collectors.toCollection(LinkedHashSet::new))
+                .stream()
+                .toList();


혹시 여기서 LinkedHashSet::new 으로 변환했다가 다시 List로 변환하는게 중복 제거 때문인가요?? 그렇다면 .distinct()를 쓰는 방법도 괜찮을 것 같아요

java 진짜 좋은 언어네요.

- songIds를 Set으로 변환하지 않고 List로 직접 전달 - artistIds 중복 제거를 LinkedHashSet 대신 .distinct() 사용 🤖 Generated with [Claude Code](https://claude.com/claude-code) Co-Authored-By: Claude Opus 4.5 <[email protected]>

feat: TopArtist 갱신을 위한 배치 작업 구현

ab618f8

gwagjiug requested review from ch1hyun and jher235 January 2, 2026 16:38

gwagjiug self-assigned this Jan 2, 2026

gwagjiug commented Jan 2, 2026

View reviewed changes

fix: TOP_ARTIST_SYNC 를 TOP_ARTIST_SYNC_JOB으로 수정하여 일관성 개선

25afad1

gwagjiug changed the title ~~feat: TopArtist 갱신을 위한 배치 작업 구현~~ CONFETI-77 feat: TopArtist 갱신을 위한 배치 작업 구현 Jan 2, 2026

ch1hyun approved these changes Jan 3, 2026

View reviewed changes

jher235 approved these changes Jan 3, 2026

View reviewed changes

gwagjiug and others added 3 commits January 3, 2026 13:16

fix: 코드리뷰 반영

b38eeab

fix: build 에러해결

1d80a71

gwagjiug merged commit b39316a into develop Jan 3, 2026
1 check passed

gwagjiug deleted the CONFETI-77-top-artist-갱신을-위한-배치-작업-구현 branch January 3, 2026 04:37

		@JoinColumn(name = "artist_id", unique = true)
		@Column(name = "artist_id", nullable = false, unique = true)


		private final TopArtistRepository topArtistRepository;

		@Transactional

CONFETI-77 feat: TopArtist 갱신을 위한 배치 작업 구현 #9

CONFETI-77 feat: TopArtist 갱신을 위한 배치 작업 구현 #9

Uh oh!

Conversation

gwagjiug commented Jan 2, 2026

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

gwagjiug Jan 2, 2026 • edited Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

ch1hyun left a comment

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

jher235 left a comment

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Uh oh!

Reviewers

Assignees

Labels

Projects

Milestone

Development

Uh oh!

4 participants

gwagjiug Jan 2, 2026 •

edited

Loading