[인프라]
- 종목(코인, 주식)별 실시간 데이터 유저에게 전달
- Upbit API 와 Websocket을 통한 실시간 시세 데이터 Kafka 에 적재
- Redis pub/sub 기능을 활용한 유저 구독 정보를 확인하여 필요한 종목의 데이터만 처리
- 유저Id 기반 Websocket 연결을 통한 데이터 송신
- Redis Sentinel 을 이용한 장애 대응 구축
- Master - Slave 구조 (3개의 Sentinel, 2개의 Slave, 1개의 Master)
- Kafka Cluster 구조 3개의 브로커로 구성하여 LEADER, FOLLOWERS 구조 구현
[데이터 수집]
- 기업 주요 재무 지표 수집
- Spring Batch를 통한 스케줄링
- DART API를 통한 기업 고유 번호 수집
- DART API를 통한 기업 주요 재무 지표 수집
- 공시 자료 정보 수집
- DART API를 호출하여 공시 자료(보고서 포함) 수집 후 Elasticsearch에 인덱싱
- Kibana로 Elasticsearch 인덱스 관리 및 시각화
[api]
- Elasticsearch를 이용한 공시 자료 검색, 상세 조회(보고서) 기능 제공
- 기업 주요 재무 상세 조회 및 검색
- 관심 기업 및 종목 생성, 삭제, 목록 조회
- 관심 주식, 코인 종목 생성, 조회 및 상세조회
- 주식,코인 종목 상세 조회 및 검색
- 공시 자료 검색, 상세 조회(보고서) 기능 제공
- 조회수에 따른 핫토픽 top N 기업 조회
- 등략률에 따른 종목 BEST/WORST 캐싱 기능 제공
[모니터링]
- ELASTIC STACK 을 이용한 서비스 로그 모니터링
- JMX, KAFKA EXPORTER 를 활용한 Kafka Cluster 성능 모니터링
- MetricBeats 를 활용한 ELK, REDIS 성능 모니터링
- Actuator, Promethues, Grafana 를 활용한 애플리케이션 성능 모니터링