일별 통계를 저장하는 배치 설계

요구사항은 단순하다.

하루에 한 번 실행
'어제' 기준으로 집계
중복 실행이 되어도 안전

이를 위해 NestJS의 Task Scheduling 기능인 Cron 기능을 사용한다.

// service

@Cron('0 5 0 * * *')
async syncDailyTrafficToDb(): Promise<void> {
    const dateStr = format(subDays(new Date(), 1), 'yyyy-MM-dd', {
        locale: ko,
    });

    const dateForDb = new Date(dateStr + 'T00:00:00Z');

    const hllKey = `visits:hll:${dateStr}`;
    const countKey = `visits:count:${dateStr}`;

    const dau = await this.redis.client.pfcount(hllKey);
    const pvRaw = await this.redis.client.get(countKey);
    const pv = pvRaw ? parseInt(pvRaw, 10) : 0;

    // DB 저장
    await this.prisma.dailyTrafficStat.upsert({
        where: { date: dateForDb },
        update: { dau, pv },
        create: { date: dateForDb, dau, pv },
    });

    // Redis 값 삭제
    await this.redis.client.del(hllKey, countKey);       
}

배치는 새벽 0시 5분에 실행 되도록 설정 했다.

DAU는 HyperLogLog로 집계된 방문자의 고유한 값을 Count
PV는 값이 없으면 0
Upsert 메서드를 사용
- 이미 데이터가 있으면 update
- 없으면 create

예상치 못한 문제: 날짜 관련

배포한 블로그에서 실행된 배치작업의 집계 날짜와 로컬에서 실행된 배치작업의 집계 날짜가 다르다.

1월 30일에 실행 된 배치작업에서 1월 28일로 들어가있다.

원인은 타임존 문제다.

로컬 : Asia/Seoul
배포서버 : UTC
DB : UTC

일단 배포한 서버의 Build Variable로 타임존을 Asia/Seoul로 적용했다.

const dateStr = format(subDays(new Date(), 1), 'yyyy-MM-dd', {
        locale: ko,
    });

이 dateStr 에는 한국 시로 하루 전의 날짜가 저장된다. 예) 오늘이 '2026-01-31' 이면 '2026-01-30'

    await this.prisma.dailyTrafficStat.upsert({
        where: { date: dateForDb },
        update: { dau, pv },
        create: { date: dateForDb, dau, pv },
    });

하지만 Prisma의 Date 저장은 UTC로 변환이 된다.

그래서 하루 전 날짜의 -9시간이 되어, 만약 자정 근처의 시간이었다면 하루가 더 밀릴 수 있다.

const dateForDb = new Date(dateStr + 'T00:00:00Z');

그래서 DB 저장을 위한 날짜로, 위에서 계산한 전날 잘짜를 다시 UTC 기준으로 돌린 뒤 Date 객체를 생성하면 +9시간의 KST 기준 시간이 나온다.

이 값을 Prisma의 날짜에 넣으면 다시 -9시간이 되어 원하는 KST 기준의 날짜로 저장되게 된다.

사실, 이 보다 더 완벽한 해결방법이 있을수도 있다.

날짜/시간 문제는 실제로 겪어보지 않으면 놓치기 쉽다.

마무리

정리하고 나니, 기능 자체만 보면 결코 거창하거나 복잡한 구현은 아니었다고 느껴진다.

오히려 대부분의 서비스에서 한 번쯤은 마주하게 되는, 아주 기본적인 기능에 가깝다.

다만, 기능의 크기보다도 어떤 관점에서 바라보고 설계하느냐가 중요한 것 같다.

단순히 '방문자 수를 센다' 가 아니라

무엇을 방문자로 정의할 것인지
실시간 데이터와 확정된 데이터를 어떻게 나눌 것인지

이런 질문들을 하나씩 정리해보는 경험이 의미있던 작업이라고 생각한다.

다음으로는 이런 경험을 기반으로

관리자 대시보드
인기글 랭킹
실시간 알림

등과 같은 기능들로 자연스럽게 확장을 해볼 계획이다.

차근차근 커뮤니티에 가까워지고 있다.

개인 블로그 방문자 수 직접 집계하기 (3)

댓글

댓글