MQTT 3.1.1/5.0, HTTP(S), WebSocket, gRPC(옵션), OPC UA(옵션).
솔루션실시간 텔레메트리요금: 별도문의
실시간 텔레메트리 (Real-time Telemetry)
디바이스/애플리케이션에서 발생하는 이벤트를 초 단위로 수집·처리·보관·시각화합니다. MQTT/HTTP/WebSocket 수집, 스트림 처리(윈도우/집계/이상탐지), 지연 수 초 목표의 알림까지 한 번에.
스파이크 흡수용 큐/로그(예: Kafka/Redis Streams) + 재시도/순서 보장.
슬라이딩/텀블링 윈도우, 세션 윈도우, 조인/패턴 매칭.
지표 대시보드, 임계/이상 감지, 웹훅/이메일/슬랙 알림.
참조 아키텍처(요약)
Edge 게이트웨이 — TLS, 장치 인증(키/토큰), 압축/배치 업로드.
Ingress — MQTT 브로커/HTTP 게이트, 레이트 제한, QoS1/2(옵션).
버퍼/스트림 — Kafka/Redis Streams로 스파이크 흡수, DLQ.
처리 — Flink/Spark/Faust로 윈도우/집계/패턴/CEP.
저장 — 시계열(TSDB), 객체 스토리지(원시), 검색(옵션).
시각화 — 대시보드/차트/탐색, 임계/이상 알림.
거버넌스 — 멀티 테넌시, 데이터 보존정책/다운샘플링.
보안 — TLS/SASL/OAuth2, 네트워크 ACL, 디도스보호(프록시).
수집 프로토콜 비교
| 프로토콜 | 특징 | 적합 사례 |
|---|---|---|
| MQTT | QoS 0/1/2, 경량, Pub/Sub, 유지메시지 | 센서/IoT, 이동통신 환경 |
| HTTP | 단순/광범위, 배치 업로드 용이 | 앱/서버 지표, 게이트웨이 업로드 |
| WebSocket | 양방향, 실시간 푸시 | 대시보드 스트리밍, 알림 |
예시: 텔레메트리 JSON
{
"device_id": "truck-013",
"ts": 1735641604123,
"metrics": {"temp": 22.7, "speed": 72.3, "fuel": 58.1},
"geo": {"lat": 37.394, "lon": 127.110},
"tags": {"fleet": "seoul-east", "model": "X200"}
}
예시: MQTT 퍼블리시
# topic: telemetry/truck-013 # QoS: 1 (at-least-once) # payload: 위 JSON 그대로
윈도우/집계 기법
| 기법 | 설명 | 예시 |
|---|---|---|
| 텀블링 윈도우 | 고정 간격, 겹침 없음 | 1분 평균 속도, 5분 합계 |
| 슬라이딩 윈도우 | 고정 간격, 겹침 있음 | 30초마다 5분 p95 지연 |
| 세션 윈도우 | 유휴 간격 기반 | 장치 활동 세션별 통계 |
예시: Flink SQL
SELECT TUMBLE_START(proctime, INTERVAL '1' MINUTE) AS window_start, device_id, AVG(metrics.temp) AS avg_temp, MAX(metrics.speed) AS max_speed FROM telemetry GROUP BY TUMBLE(proctime, INTERVAL '1' MINUTE), device_id;
스키마 관리
스키마 레지스트리(옵션)로 진화형 스키마 관리, 호환성 체크(Backward/Full), DLQ로 예외 격리.
저장 계층
| 계층 | 기술 예시 | 용도 |
|---|---|---|
| 핫(시계열) | InfluxDB/TimescaleDB/ClickHouse | 최근 n일 조회/알람 |
| 웜(검색) | OpenSearch/Elasticsearch | 검색/필터/탐색 |
| 콜드(원시) | 오브젝트 스토리지 | 장기 보관, 재처리 |
| * 보존기간, 다운샘플링(p50/p95/p99), 파티셔닝은 워크로드에 맞춰 설계. | ||
알림 규칙 예시
| 규칙 | 조건 | 채널 |
|---|---|---|
| 온도 급등 | avg(temp, 5m) > 80℃ | Slack/Webhook/Email |
| 유휴 | 세션 10분 무이벤트 | Webhook |
| 이상 패턴 | z-score > 3 혹은 IQR 상회 | Slack |
알림 억제(예: 10분 이내 중복 방지), 승급(Info→Warn→Critical), 온콜 스케줄 연동 가능.
운영/거버넌스
멀티 테넌시 — 프로젝트/조직 라우팅, 토픽 네임스페이스.
보안 — TLS, 토큰/클라이언트 인증, 네트워크 ACL, 디도스보호(프록시).
관찰성 — 수집율, 유실율, 처리지연 p50/p95/p99, DLQ 카운트.
확장 — 파티션/샤드 스케일아웃, 오토스케일(옵션).
배포 — 카나리/블루그린, 롤백/리플레이.
규정 — 보존기간/암호화/감사로그, 지역 정책.
요금 안내
요금: 별도문의
초당 이벤트 수(EPS), 총 장치 수, 저장 계층(핫/웜/콜드)와 보존기간, 알림 채널 수에 따라 산정됩니다.
수 초 내 인사이트, 실시간 텔레메트리로
장치/앱의 이벤트 파이프라인을 설계해 드립니다. 요구사항을 알려주세요.
실시간 텔레메트리 문의
ℹ️
개인정보 처리 안내
문의 응대를 위해서만 사용되며 일정 기간 후 파기됩니다.