👋 챕터 소개

안녕하세요, loguru 완전 정복의 마지막 실습에 오신 것을 환영합니다! 우리는 지금까지 로그를 터미널과 파일에 아주 훌륭하게 기록해왔습니다. 하지만 서비스에 치명적인 오류가 새벽 3시에 발생한다면, 다음 날 아침에 로그 파일을 열어보기 전까지는 아무도 그 사실을 알 수 없겠죠? 😨

이번 챕터에서는 loguru의 확장성을 최대로 활용하여, 우리의 로깅 시스템을 실시간 **'장애 감지 및 알림 시스템'**으로 진화시켜 보겠습니다. loguru의 커스텀 싱크(Sink) 기능을 사용하여, ERROR 레벨 이상의 로그가 발생했을 때 개발팀의 필수 협업 도구인 **슬랙(Slack)**으로 즉시 알림을 보내는 기능을 구현해 봅니다! 🔔

🎯 챕터 목표

이번 챕터를 마치면 여러분은 다음을 할 수 있게 될 거예요!

프로덕션 환경에서 실시간 에러 알림의 중요성을 이해합니다.
Slack Incoming Webhook을 설정하고 URL을 발급받을 수 있습니다.
민감한 정보인 Webhook URL을 환경 변수로 안전하게 관리하는 방법을 익힙니다.
로그 메시지를 인자로 받는 커스텀 싱크(Sink) 함수를 작성할 수 있습니다.
logger.add()에 커스텀 싱크 함수를 등록하고, level 필터를 적용하여 심각한 오류만 Slack으로 전송할 수 있습니다.

💻 이번 챕터에서 사용되는 전체 코드 및 프로젝트 구조

loguru-mastery 폴더에 slack_alert.py 파일을 새로 추가하여 실습을 진행합니다. 이 코드는 ERROR 레벨의 로그가 발생했을 때, 설정된 Slack 채널로 알림을 보냅니다.

프로젝트 구조

loguru-mastery/
├── venv/
├── requirements.txt         <- slack-sdk 라이브러리 추가
└── slack_alert.py           <- 새로 추가된 파일!

requirements.txt 예시
```
loguru
slack-sdk
```

slack_alert.py 전체 코드 (Slack SDK 사용, 정정본)

# slack_alert.py
import os
import sys
import traceback
from loguru import logger
from slack_sdk.webhook import WebhookClient  # SDK의 Webhook 클라이언트 사용

# --- 1. Slack Webhook URL 설정 ---
# 🚨 절대 코드에 URL을 직접 넣지 마세요! 보안상 매우 위험합니다.
#    반드시 환경 변수를 통해 URL을 불러옵니다.
SLACK_WEBHOOK_URL = os.getenv("SLACK_WEBHOOK_URL")

# --- 2. Loguru 커스텀 싱크(Sink) 함수 정의 ---
# 함수 싱크는 포맷된 문자열이 아니라, loguru의 Message 객체를 전달받습니다.
# message.record에 level/name/exception 등 세부 정보가 들어 있습니다.
def slack_sink(message):
    record = message.record
    log_text = record["message"]

    # 예외가 있으면 사람이 읽기 쉬운 트레이스백으로 변환
    exc = record["exception"]
    if exc:
        tb = "".join(traceback.format_exception(exc.type, exc.value, exc.traceback))
    else:
        tb = ""

    payload = {
        "text": "🚨 프로덕션 서버에 오류가 발생했습니다! 🚨",
        "attachments": [{
            "color": "#FF0000",
            "fields": [
                {"title": "Level", "value": record["level"].name, "short": True},
                {"title": "Module", "value": record["module"], "short": True},
                {"title": "Message", "value": log_text or "-", "short": False},
                {
                    "title": "Error Traceback",
                    "value": f"```{tb}```" if tb else "N/A",
                    "short": False
                },
            ]
        }]
    }

    try:
        WebhookClient(SLACK_WEBHOOK_URL).send(**payload)
    except Exception as e:
        # 여기서 logger를 다시 호출하면 재귀 위험 -> stderr만 사용
        sys.stderr.write(f"[Slack sink] 전송 실패: {e}\\\\n")

# --- 3. Loguru 로거 설정 ---
logger.remove()

# 싱크 1: 콘솔 출력 (모든 DEBUG 레벨 이상의 로그)
logger.add(sys.stderr, level="DEBUG")

# 싱크 2: 슬랙 알림 (ERROR 레벨 이상의 심각한 로그만!)
if SLACK_WEBHOOK_URL:
    # 함수 싱크는 Message 객체를 받으므로 format 지정 불필요
    logger.add(
        slack_sink,            # 우리가 만든 함수를 싱크로 지정!
        level="ERROR",         # ERROR 레벨 이상일 때만 이 싱크가 동작
        backtrace=True,       
        diagnose=False,        # 운영 환경에서 과도한 로컬 변수 노출 방지
        enqueue=True           # 비동기 큐로 전송(애플리케이션 흐름 지연 최소화)
    )
else:
    # 환경 변수가 설정되지 않았을 경우 경고 메시지 출력
    logger.warning("SLACK_WEBHOOK_URL 환경 변수가 없어 슬랙 알림이 비활성화되었습니다.")

# --- 4. 로직 실행 및 테스트 ---
def critical_task():
    logger.info("일일 사용자 데이터 집계 작업을 시작합니다.")
    logger.debug("데이터베이스에서 사용자 목록을 가져옵니다...")

    try:
        # 의도적으로 에러 발생!
        result = 10 / 0
    except ZeroDivisionError:
        # logger.exception()은 예외 정보를 자동으로 로그에 포함시킵니다.
        # 이 로그는 ERROR 레벨이므로, 콘솔과 슬랙 양쪽에 모두 기록됩니다.
        logger.exception("데이터 집계 중 치명적인 오류가 발생하여 작업을 중단합니다.")

if __name__ == "__main__":
    critical_task()

👋 챕터 소개

🎯 챕터 목표

💻 이번 챕터에서 사용되는 전체 코드 및 프로젝트 구조

📖 강의 내용