Abseil Code Review · 61/79

Abseil LogEntry·structured logging

2026년 6월 12일 · Hawk · 2분 읽기

#LogEntry — Sink가 보는 인터페이스

LogSink::Send가 받는 absl::LogEntry는 한 로그 호출의 모든 메타데이터를 노출한다.

1
class LogEntry {
2
public:
3
    absl::LogSeverity log_severity() const;
4
    int verbosity() const;                 // VLOG 레벨, LOG는 kNoVerbosityLevel
5
    absl::Time timestamp() const;
6
    absl::LogEntry::tid_t tid() const;     // thread id
7
    absl::string_view source_filename() const;
8
    absl::string_view source_basename() const;
9
    int source_line() const;
10
    bool prefix() const;                   // 헤더 포함 여부
11

12
    absl::string_view text_message() const;             // 본문만
13
    absl::string_view text_message_with_prefix() const; // "Iyyyymmdd ..." 포함
14

15
    // 구조화 (future-friendly)
16
    bool is_perror() const;
17
    absl::string_view text_message_with_prefix_and_newline() const;
18
};

이걸 활용해 다음을 자동 추출한다.

severity로 alert 라우팅
source_filename + line으로 검색 키
timestamp로 시계열 인덱스
tid로 thread별 trace

#JSON 변환 예

1
class JsonSink : public absl::LogSink {
2
public:
3
    void Send(const absl::LogEntry& entry) override {
4
        absl::flat_hash_map<std::string, std::string> kv = {
5
            {"severity", absl::LogSeverityName(entry.log_severity())},
6
            {"ts", absl::FormatTime(absl::RFC3339_full, entry.timestamp(), absl::UTCTimeZone())},
7
            {"file", std::string(entry.source_basename())},
8
            {"line", absl::StrCat(entry.source_line())},
9
            {"tid", absl::StrCat(entry.tid())},
10
            {"msg", std::string(entry.text_message())},
11
        };
12
        std::cerr << ToJson(kv) << "\n";
13
    }
14
};

ELK·Loki·CloudWatch 등 JSON 한 줄 입력을 받는 시스템에 그대로 송신 가능.

#구조화 로깅의 진짜 의미

전통적 텍스트 로그:

1
I20260525 13:00:00 12345 user.cc:42] user 123 logged in from 10.0.0.5

이 한 줄에서 user_id, ip를 정규식으로 파싱 해야 한다. 메시지 형식이 바뀌면 파서가 깨진다.

구조화 로깅은 key-value를 처음부터 분리.

1
{"severity":"INFO","ts":"2026-05-25T13:00:00Z","file":"user.cc","line":42,
2
 "msg":"user logged in","user_id":123,"ip":"10.0.0.5"}

Abseil의 LogEntry는 기본 metadata만 분리한다. 사용자 페이로드의 key-value는 직접 인코딩해야 한다.

#커스텀 field 추가 — 메시지에 인코딩

가장 단순한 방법은 메시지 본문에 구조화 토큰을 박는 것.

1
LOG(INFO) << "user_login user_id=" << user.id << " ip=" << client_ip;

sink에서 메시지를 파싱(absl::StrSplit)해 KV 추출. 표준화가 안 된 만큼 팀 컨벤션 이 중요.

더 형식적인 접근은 absl::Cord나 protobuf 페이로드를 직렬화해 메시지에 담는 것. 하지만 Abseil은 직접적인 structured 필드 API를 아직 노출하지 않는다.

#코드 리뷰 패턴

1
// 회피 — 문자열 보간으로 KV
2
LOG(INFO) << "user " << id << " from " << ip << " action " << action;
3
// 파싱이 어려움 (key가 명시 안 됨)
4

5
// Good — key=value 형식 통일
6
LOG(INFO) << "user_login user_id=" << id << " ip=" << ip << " action=" << action;

1
// 회피 — 메시지를 동적으로 만들어 검색이 어려움
2
LOG(INFO) << absl::StrCat("user ", id, " ", action_string);
3

4
// Good — 고정 prefix + 동적 부분 분리
5
LOG(INFO) << "audit event=" << action_string << " user_id=" << id;

prefix가 grep 가능한 고정 토큰 이어야 운영 중 검색이 쉽다.

#logging 레벨 활용

LogEntry::log_severity()를 보고 destination을 나눈다.

1
void Send(const absl::LogEntry& entry) override {
2
    switch (entry.log_severity()) {
3
        case absl::LogSeverity::kError:
4
        case absl::LogSeverity::kFatal:
5
            SendToAlerts(entry);
6
            break;
7
        default:
8
            SendToLogs(entry);
9
    }
10
}

ERROR 이상만 PagerDuty, 나머지는 일반 로그 시스템.

#source location 활용

1
void Send(const absl::LogEntry& entry) override {
2
    // file:line을 자동 태그로
3
    std::string tag = absl::StrCat(entry.source_basename(), ":", entry.source_line());
4
    metrics->Increment("log_count", {{"location", tag}});
5
}

자주 발생하는 ERROR의 위치 가 자동으로 metric label이 된다. 운영 중 hotspot 발견에 유용.

#시간 정밀도

entry.timestamp()는 absl::Time. 나노초 정밀도지만 RFC3339_full 출력 시 ns까지 포함된다. 분산 trace 상관관계에 충분.

1
absl::FormatTime(absl::RFC3339_full, entry.timestamp(), absl::UTCTimeZone());
2
// "2026-05-25T13:00:00.123456789+00:00"

#작은 예시 — Loki/Cloud-friendly JSON sink

1
class LokiSink : public absl::LogSink {
2
public:
3
    LokiSink(std::string service, std::string env)
4
        : service_(std::move(service)), env_(std::move(env)) {}
5

6
    void Send(const absl::LogEntry& entry) override {
7
        absl::Time ts = entry.timestamp();
8
        std::string line = absl::StrCat(
9
            "{\"ts\":\"", absl::FormatTime(absl::RFC3339_full, ts, absl::UTCTimeZone()), "\",",
10
            "\"service\":\"", service_, "\",",
11
            "\"env\":\"", env_, "\",",
12
            "\"severity\":\"", absl::LogSeverityName(entry.log_severity()), "\",",
13
            "\"file\":\"", entry.source_basename(), ":", entry.source_line(), "\",",
14
            "\"tid\":", entry.tid(), ",",
15
            "\"msg\":\"", EscapeJson(entry.text_message()), "\"}\n");
16

17
        queue_.Push(std::move(line));   // 비동기 worker가 HTTP POST
18
    }
19

20
    void Flush() override { queue_.Drain(); }
21

22
private:
23
    std::string service_;
24
    std::string env_;
25
    AsyncQueue queue_;
26
};
27

28
// 등록
29
LokiSink loki("user-svc", "prod");
30
absl::AddLogSink(&loki);