๋ชฉ์
OpenCV๊ฐ publishํ๋ Redis progress ๋ฉ์์ง์ channel, payload, enum, ์์, jobId ์ผ์น ์ฌ๋ถ๋ฅผ ์๋ ๊ฒ์ฆํ๋ค.
๋ฐฐ๊ฒฝ
Redis Pub/Sub์ schema๊ฐ ๊ฐ์ ๋์ง ์๋๋ค. payload enum์ด ํ๋ฆฌ๊ฑฐ๋ channel jobId์ payload jobId๊ฐ ๋ค๋ฅด๋ฉด SSE ์งํ๋ฅ ์ด ๋๋ฝ๋๊ฑฐ๋ ์๋ชป๋ ์ฌ์ฉ์์๊ฒ ์ ๋ฌ๋ ์ ์๋ค.
์์
๋ฒ์
์์ฉ ๊ธฐ์ค
์ธก์ ์งํ
- invalid payload rejection rate
- contract test pass count
- contract test failure count
- Redis message processing latency
ํธ๋ ์ด๋์คํ
์ ํํ ๋ฐฉ์: ํ์ฌ Pub/Sub ๊ณ์ฝ์ ๋จผ์ ๊ณ ์ ํ๊ณ ํ
์คํธํ๋ค.
ํฌ๊ธฐํ ๋ฐฉ์: ์ฆ์ Redis Stream์ผ๋ก ์ ํํ์ง ์๋๋ค.
์ด์ : ํ์ฌ ์ด์ ํ๋ฆ์ ์์ ์ฑ์ ๋จผ์ ์์นํํด์ผ Stream ์ ํ์ ์ด๋์ ๋น๊ตํ ์ ์๋ค.
๋ชฉ์
OpenCV๊ฐ publishํ๋ Redis progress ๋ฉ์์ง์ channel, payload, enum, ์์, jobId ์ผ์น ์ฌ๋ถ๋ฅผ ์๋ ๊ฒ์ฆํ๋ค.
๋ฐฐ๊ฒฝ
Redis Pub/Sub์ schema๊ฐ ๊ฐ์ ๋์ง ์๋๋ค. payload enum์ด ํ๋ฆฌ๊ฑฐ๋ channel jobId์ payload jobId๊ฐ ๋ค๋ฅด๋ฉด SSE ์งํ๋ฅ ์ด ๋๋ฝ๋๊ฑฐ๋ ์๋ชป๋ ์ฌ์ฉ์์๊ฒ ์ ๋ฌ๋ ์ ์๋ค.
์์ ๋ฒ์
์์ฉ ๊ธฐ์ค
UPLOADING,UPLOAD_COMPLETE,PROCESSING,COMPLETE๋ง ํ์ฉ๋์ด์ผ ํ๋ค.์ธก์ ์งํ
ํธ๋ ์ด๋์คํ
์ ํํ ๋ฐฉ์: ํ์ฌ Pub/Sub ๊ณ์ฝ์ ๋จผ์ ๊ณ ์ ํ๊ณ ํ ์คํธํ๋ค.
ํฌ๊ธฐํ ๋ฐฉ์: ์ฆ์ Redis Stream์ผ๋ก ์ ํํ์ง ์๋๋ค.
์ด์ : ํ์ฌ ์ด์ ํ๋ฆ์ ์์ ์ฑ์ ๋จผ์ ์์นํํด์ผ Stream ์ ํ์ ์ด๋์ ๋น๊ตํ ์ ์๋ค.