Overview›Solutions›CodeStream
분류 · Solution CBST

CodeStream 분류

실시간 스트리밍 분류. CODEBAILEY 분류 카테고리의 핵심 솔루션으로, 엔터프라이즈 환경에서 검증된 안정성과 성능을 제공합니다.

CBST
Solution Code
99.9%
시스템 가용성
2주
POC 기간
24 / 7
기술 지원
Product Preview

실제 콘솔 화면 미리보기

CodeStream 콘솔에서 분산된 데이터 자산을 한눈에 모니터링하고, 파이프라인을 실시간으로 운영합니다.

데모 요청
https://app.codebailey.com/stream/workspace/prod/dashboard
Production Workspace · Stream Processing
● All topologies healthy
Events / sec
1.8M
Active Topologies
12 / 14
Consumer Lag
2.4K
p99 Latency
62ms
Topology · clickstream_classify
Kafka Source › Deserialize › Enrich › Classify › Sink
Recent Activity
09:41:07throughput · clickstream_classify holding 1.8M ev/sOK
09:40:52partition · txn_fraud_stream rebalanced 24 → 32OK
09:40:18lag · iot_sensor_route consumer lag +9.2KWARN
09:39:44checkpoint · state snapshot committed (3.1 GB)OK
09:38:59backpressure · enrich operator at 87% bufferWARN
Topologies · Search & Browse
⌕ Filter: active
⌕ source:kafka AND state:running 14 topologies registered
All Streams Kafka (9) Kinesis (3) Pulsar (2) Paused (2)
Stream Job
State
Owner
Throughput
stream.clickstream_classify
Runningsource:kafka
stream-platform
1.8M ev/s
›
stream.txn_fraud_stream
Runningsource:kafka
risk-eng
420K ev/s
›
stream.iot_sensor_route
Runningsource:kinesis
edge-team
9.2K lag
›
stream.order_events_enrich
Runningsource:kafka
commerce
680K ev/s
›
stream.log_anomaly_detect
Runningsource:pulsar
sre
155K ev/s
›
stream.cdc_replicate_dw
Pausedsource:kinesis
data-eng
paused 12m
›
Topology · clickstream_classify
12 operators · 1.8M events/s
Stream Topology
Sources
clicks.rawkafka · 32p
sessions.refkafka · 8p
geo.lookupcompacted
Ingest
deserializeavro · schema
Transform
enrich + joinkeyed state
Operators
classifymodel · v3
window aggtumbling 5s
Sinks
events.classifiedkafka topic
metrics.olapclickhouse
Impact Analysis · 변경 영향도
downstreamevents.classified · 다운스트림 컨슈머 6개HIGH
analyticsmetrics.olap · 실시간 대시보드 sinkMED
alertingfraud_alert_consumerMED
archives3_cold_sink · 배치 적재LOW
How It Works

5단계 워크플로우

분류 도메인의 전 주기를 자동화된 파이프라인으로 처리합니다.

STEP 01

Ingest

텍스트 · 이미지 · 정형 데이터 등 다양한 형식의 분류 대상을 통합 수집합니다.

STEP 02

Preprocess

토큰화 · 정규화 · 임베딩 변환으로 모델 입력 형태로 가공합니다.

STEP 03

Inference

GPT · BERT · Llama 등 다중 모델로 분류 추론을 병렬 실행합니다.

STEP 04

Threshold

임계값 기반 분류 결정과 낮은 신뢰도 항목의 휴먼 리뷰 라우팅을 처리합니다.

STEP 05

Output

분류 결과를 카탈로그 · 다운스트림 시스템 · API로 즉시 배포합니다.

Core Capabilities

8가지 핵심 기능

분류 운영에 필요한 모든 기능을 단일 플랫폼에서 통합 제공합니다.

ML

Multi-Model

GPT · BERT · Llama · Claude 등 다중 LLM 모델 라우팅과 폴백을 지원합니다.

RT

Real-time

평균 50ms 응답과 100K ops/s 처리량으로 실시간 분류를 처리합니다.

BT

Batch Process

Spark 분산 처리로 수억 건 단위 대용량 일괄 분류를 안정적으로 실행합니다.

RE

Rule Engine

규칙 기반 분류와 ML 모델을 결합한 하이브리드 분류 엔진을 제공합니다.

AL

Active Learning

사용자 피드백을 학습 데이터로 자동 수집해 모델 정확도를 지속 개선합니다.

FB

Feedback Loop

분류 결과 모니터링 · 드리프트 탐지 · 자동 재학습 트리거를 운영합니다.

CS

Confidence Score

신뢰도 점수 기반 임계값 분기와 낮은 점수의 휴먼 리뷰 라우팅을 처리합니다.

MC

Multi-class

1000+ 클래스 · 계층 분류 · 다중 레이블 분류를 단일 모델로 지원합니다.

Differentiators

CodeStream만의 핵심 차별점

배치가 아니라 초당 수백만 건의 이벤트를 흐르는 그대로 분류하고, 상태 기반 연산과 백프레셔 제어로 멈춤 없는 실시간 파이프라인을 운영하는 것이 CodeStream의 핵심입니다.

전체 솔루션

초고속
스트림 분류

이벤트가 도착하는 즉시 분류해 지연 없는 실시간 의사결정을 지원합니다.

  • 초당 180만+ 이벤트 처리
  • p99 62ms 저지연 추론
  • Kafka · Kinesis · Pulsar 소스 연동
  • 다중 LLM 모델 인라인 분류

상태 기반
토폴로지

Enrich · Join · Window 연산을 코드 없이 토폴로지로 구성합니다.

  • keyed state 기반 enrich · join
  • Tumbling · Sliding 윈도우 집계
  • Avro 스키마 역직렬화 · 검증
  • 토폴로지 비주얼 편집 · 배포

무중단
운영 & 복원

부하 급증에도 흐름이 끊기지 않도록 자동으로 처리량을 조절합니다.

  • 백프레셔 자동 감지 · 흐름 제어
  • 파티션 동적 리밸런싱
  • 체크포인트 기반 상태 스냅샷 · 복구
  • 컨슈머 랙 실시간 모니터링
Developer Experience

API & SDK 예제 코드

REST · SDK · CLI — 개발자가 즉시 통합 가능한 형태로 API를 제공합니다.

# 분류 요청 (단건)
curl -X POST "https://api.codebailey.com/v1/stream/classify" \
  -H "Authorization: Bearer $CBST_TOKEN" \
  -H "Content-Type: application/json" \
  -d '{
    "model": "support_ticket_priority/v3",
    "input": { "subject": "결제가 안 됩니다", "body": "..." },
    "options": { "min_confidence": 0.85, "explain": true }
  }'

# Response · 200 OK
{
  "label": "P0",
  "confidence": 0.94,
  "alternatives": [{ "label": "P1", "confidence": 0.05 }],
  "explain": { "top_tokens": ["결제", "안", "됩니다"] }
}
Use Cases

활용 사례

CodeStream이(가) 실제로 활용되는 대표적인 산업 시나리오.

CASE 01
CX
· 고객지원
고객 문의 · 리뷰 · 채팅을 실시간 자동 분류해 우선순위 라우팅과 자동 응답을 처리합니다.
CASE 02
금융
· 리스크
거래 패턴 · 문서 분류 · 사기 탐지에 LLM을 적용해 컴플라이언스 비용을 절감합니다.
CASE 03
커머스
· 제조
상품 카테고리 분류 · 결함 패턴 · 품질 등급 자동화로 운영 효율을 높입니다.
Technical Specifications

기술 사양 명세서

성능 · 확장성 · API · 데이터 소스 · 보안 · 배포의 6개 영역으로 정리한 프로덕션 명세.

SPEC 01
Performance & SLA
평균 응답 시간 (p95)
< 200 ms
평균 응답 시간 (p99)
< 500 ms
최대 처리량
100,000 ops / s
가용성 SLA
99.99% (3-AZ)
RPO / RTO
< 1 hour / < 1 hour
SPEC 02
Scalability
최대 카탈로그 자산
10M+ assets
동시 사용자
5,000 concurrent
파이프라인 동시 실행
200+ parallel
스케일 모델
Horizontal · Stateless
멀티 테넌시
Workspace-level isolation
SPEC 03
APIs & Protocols
REST API
OpenAPI 3.1 · v1
GraphQL
Spec compliant · Subscriptions
SDKs
PythonJavaNode.jsGo
CLI
codebailey-cli (macOS · Linux · Win)
Event Streaming
Kafka · Webhooks · SSE
SPEC 04
Data Sources Supported
RDBMS
OraclePostgreSQLMySQLMSSQLDB2
Data Warehouse
SnowflakeBigQueryRedshiftDatabricks
Lake / Table Format
IcebergDelta LakeHudiParquet
Messaging
KafkaPulsarKinesisRabbitMQ
SaaS Connectors
142+ (Salesforce, HubSpot 등)
SPEC 05
Security & Compliance
저장 암호화
AES-256 · Envelope Encryption
전송 암호화
TLS 1.3 · mTLS 지원
접근 제어
RBAC + ABAC + Row/Col Policy
감사 로그
변조 불가 (Append-only)
규제 대응
개인정보보호법 · OWASP Top 10
SSO · IdP 연동
SAML 2.0 · OIDC · LDAP
SPEC 06
Deployment & Operations
배포 모델
SaaS · Self-hosted · Air-gapped
컨테이너 런타임
Docker · containerd
오케스트레이션
Kubernetes 1.27+
설치 방식
Helm Chart · Terraform Module
관측성
Prometheus · OpenTelemetry
기술 지원
24 / 7 (Enterprise)

CodeStream을(를)
지금 도입하세요

실시간 스트리밍 분류. 전문가와 함께 맞춤형 도입 전략을 설계해드립니다.

무료 컨설팅 신청 다른 솔루션 보기