적재API는 안동 버스정류장 별 버스 도착정보를 DB에 적재하는 역할
- 적재 프로세스 :
1. 안동버스 open api 호출 response 원문을 elasticSearch에 적재
2. http code 200이면 캐싱을 위해 redis에 적재 (타임아웃 10분)
3. kafka를 이용해서 데이터를 컨슈머에 넘김
4. 컨슈머는 kafka에 넣어진 데이터를 가져와서 JPA를 사용해 Mysql에 적재
5. 에러발생시, mongo에 exception 정보 적재
조회API는 적재된 버스 도착정보를 불러오는 역할
- 조회 프로세스:
1. Redis에 캐싱된 값이 있으면 redis에 적재되있는 값을 조회
2. Redis에 캐싱된 값이 없다면 mysql에 적재되어있는 최신 데이터을 조회
3. Redis, mysql 모두 적재된 값이 없다면 조회결과 없음을 표시
소스는 아래 주소에서 확인 가능
반응형
'작업일지 > 안동버스 API 연동' 카테고리의 다른 글
| #4) kafka로 데이터 발행(Publish)과 구독(Subscribe) 동작하기 (0) | 2021.01.22 |
|---|---|
| #3) Redis(레디스)로 캐싱하기 (0) | 2021.01.20 |
| #2) 엘라스틱서치(Elasticsearch)로 원문 데이터를 저장하기 (0) | 2021.01.18 |
| #1) 안동버스 API 연동 계획 (0) | 2021.01.18 |
