RFID/ANPR hardware event ingestion — gRPC schema, confidence scoring, Kafka raw.* topic pattern
현장 장비(RFID 리더, ANPR 카메라, RSU)에서 발생하는 원시 이벤트를 BOS로 수집하는 파이프라인을 정의한다. 모든 이벤트는 gRPC로 수신 후 Kafka raw.* 토픽에 발행된다.
| 이벤트 유형 | 소스 | Kafka 토픽 | 설명 |
|---|---|---|---|
| RFID 태그 읽기 | RFID 리더 | raw.rfid.events | TnG RFID 태그 UID + 차선 ID |
| ANPR 인식 | ANPR 카메라 | raw.anpr.events | 번호판 문자 + 신뢰도 점수 |
| RSU 이벤트 | RSU (Road Side Unit) | raw.rsu.events | MLFF 통과 속도, 타임스탬프 |
| 장비 상태 | 모든 현장 장비 | raw.equipment.heartbeat | 장비 상태 (정상/경고/오류) |
// rfid_event.proto
syntax = "proto3";
package bos.tolling.v1;
message RfidEvent {
string event_id = 1; // UUID
string device_id = 2; // 리더 장비 ID
string lane_id = 3; // 차선 ID (예: PLUS-KL-L01)
string tag_uid = 4; // TnG RFID 태그 UID
int64 captured_at_ms = 5; // Unix ms (장비 현지시각)
string direction = 6; // ENTRY / EXIT
}
message AnprEvent {
string event_id = 1;
string device_id = 2;
string lane_id = 3;
string plate_number = 4; // "WXX 1234" 형식
float confidence_score = 5; // 0.0 ~ 1.0
bytes image_data = 6; // JPEG 이미지 (선택적)
int64 captured_at_ms = 7;
string direction = 8; // ENTRY / EXIT
}
| 신뢰도 범위 | 처리 방식 |
|---|---|
| ≥ 0.95 | 자동 승인 — 트랜잭션 생성 |
| 0.80 ~ 0.94 | 조건부 승인 — RFID 크로스체크 필수 |
| 0.60 ~ 0.79 | 수동 심사 큐 등록 (manual_review_queue) |
| < 0.60 | 자동 기각 — 이벤트 폐기 (감사 로그만 기록) |
# raw.rfid.events