분류 번호 없는 도서관 — 당근이 행동 로그의 카오스를 정리한 방법

syntax = "proto3";
 
package daangn.events.commerce;
 
message ProductViewEvent {
  string event_id = 1;
  string user_id = 2;
  string product_id = 3;
  string category = 4;
  int64 timestamp_ms = 5;
  string screen_name = 6;
  string referrer = 7;
 
  enum ViewType {
    VIEW_TYPE_UNSPECIFIED = 0;
    ORGANIC = 1;
    SEARCH = 2;
    RECOMMENDATION = 3;
  }
  ViewType view_type = 8;
}
 
message ProductClickEvent {
  string event_id = 1;
  string user_id = 2;
  string product_id = 3;
  string button_name = 4;
  int64 timestamp_ms = 5;
}

event_codegen:
  triggers:
    - schema_approved
  targets:
    - platform: ios
      language: swift
      output: "daangn-events-ios/Sources/Generated/"
    - platform: android
      language: kotlin
      output: "daangn-events-android/src/generated/"
    - platform: server
      language: kotlin
      output: "daangn-events-server/src/generated/"
  validation:
    - backward_compatibility_check
    - required_fields_check
    - naming_convention_check

@RestController
class EventCollectorController(
    private val kafkaTemplate: KafkaTemplate<String, ByteArray>,
    private val eventValidator: EventValidator
) {
    @PostMapping("/v1/events")
    fun collectEvents(@RequestBody events: List<RawEvent>): ResponseEntity<CollectResult> {
        val validationResults = events.map { event ->
            val result = eventValidator.validate(event)
            if (result.isValid) {
                kafkaTemplate.send(
                    "user-events-${event.eventType}",
                    event.userId,
                    event.toProtobuf()
                )
            }
            result
        }
 
        return ResponseEntity.ok(CollectResult(
            accepted = validationResults.count { it.isValid },
            rejected = validationResults.count { !it.isValid },
            errors = validationResults.filter { !it.isValid }.map { it.error }
        ))
    }
}

이벤트_정의:
  - 전사 네이밍 컨벤션을 먼저 확립했는가
  - 이벤트 스키마를 선언적으로 관리하는가 (Protobuf, JSON Schema 등)
  - 필수 공통 필드를 정의했는가 (event_id, user_id, timestamp 등)
 
코드_생성:
  - 스키마에서 클라이언트/서버 코드를 자동 생성하는가
  - 하위 호환성 검사를 자동화했는가
  - 타입 안전한 API를 제공하는가
 
수집_파이프라인:
  - 이벤트 유효성 검증을 수집 시점에 수행하는가
  - 유실 방지를 위한 버퍼링/재시도가 있는가
  - 대시보드에서 실시간 수집 현황을 모니터링할 수 있는가
 
거버넌스:
  - 이벤트 변경에 대한 리뷰 프로세스가 있는가
  - 미사용 이벤트를 정기적으로 정리하는가
  - 데이터 분석팀과 협업 채널이 있는가