flow

flow

์›Œํฌํ”Œ๋กœ์šฐ ๋ชฉ๋ก์—์„œ [์ธ์Šคํ„ด์Šค ๋ชฉ๋ก]์„ ์„ ํƒํ•˜๋ฉด ์ธ์Šคํ„ด์Šค ์ž‘์—… ๋ชฉ๋ก์„ ํ™•์ธํ•  ์ˆ˜ ์žˆ์Šต๋‹ˆ๋‹ค.

flow001

๋ฐฐ์น˜ ์ธ์Šคํ„ด์Šค ๋ชฉ๋ก

ํ•ด๋‹น ์ธ์Šคํ„ด์Šค ๋ชฉ๋ก์„ ์„ ํƒํ•œ ํ›„ ์ธ์Šคํ„ด์Šค(์ž‘์—…) ์ •๋ณด๋ฅผ ํ™•์ธํ•ฉ๋‹ˆ๋‹ค.

flow002

  1. ํ•ด๋‹น ์›Œํฌํ”Œ๋กœ์šฐ์—์„œ ๋ฐœ์ƒํ•œ Batch job instance ๋ชฉ๋ก์„ ํ‘œ์‹œํ•œ๋‹ค.

    ํ•„๋“œ์„ค๋ช…
    ํด๋Ÿฌ์Šคํ„ฐํ•ด๋‹น batch job์ด ์‹คํ–‰๋œ cluster ์ •๋ณด
    Job ID์›Œํฌํ”Œ๋กœ์šฐ๊ฐ€ ์‹คํ–‰๋  ๋•Œ ์ƒ์„ฑ๋œ Job ID
    ์›Œํฌํ”Œ๋กœ์šฐ๋ช…์›Œํฌํ”Œ๋กœ์šฐ ์ด๋ฆ„
    ์‹œ์ž‘ ์‹œ๊ฐInstance๊ฐ€ ์‹œ์ž‘๋œ ์‹œ๊ฐ„
    ์ข…๋ฃŒ ์‹œ๊ฐInstance๊ฐ€ ์ข…๋ฃŒ๋œ ์‹œ๊ฐ„
    ์ƒํƒœ์ƒํƒœ (Running, Suspended, Killed, Succeeded)
    Actionํ•ด๋‹น Instance๋ฅผ ์ƒํƒœ์— ๋”ฐ๋ผ ์ œ์–ดํ•  ์ˆ˜ ์žˆ๋‹ค. (์‹คํ–‰, ์žฌ๊ฐœ, ์ผ์‹œ์ •์ง€, ์ข…๋ฃŒ)
    ๊ฐ Instance์˜ ์ƒํƒœ์— ๋”ฐ๋ผ ๊ทธ ์‹œ์ ์— ์‚ฌ์šฉ ๊ฐ€๋Šฅํ•œ ๋ฉ”๋‰ด๊ฐ€ ํ™œ์„ฑํ™” ๋œ๋‹ค.
  2. Job Id ํด๋ฆญ ์‹œ ํ•ด๋‹น Instance์˜ ์ƒ์„ธํ™”๋ฉด์œผ๋กœ ์ด๋™ํ•œ๋‹ค.

์ธ์Šคํ„ด์Šค ํ๋ฆ„

flow004

  1. โ€˜๋’ค๋กœ๊ฐ€๊ธฐโ€™ ๋ฒ„ํŠผ ํด๋ฆญํ•˜์—ฌ ์ธ์Šคํ„ด์Šค ๋ชฉ๋ก์œผ๋กœ ๋ณต๊ท€
  2. ์ธ์Šคํ„ด์Šค ์ƒ์„ธ ํ™”๋ฉด์—์„œ ์ œ๊ณตํ•˜๋Š” ์ •๋ณด(ํ๋ฆ„/์ƒ์„ธ/ํŒŒ๋ผ๋ฏธํ„ฐ/๋กœ๊ทธ)
  3. โ€˜ํ๋ฆ„โ€™ํƒญ์—์„œ Nodeํด๋ฆญ ์‹œ ํ•ด๋‹น Log๋ฅผ ์ œ๊ณต(INFO/STD/ERR)
  4. Node์„ ํƒ์— ๋”ฐ๋ผ ํ•ด๋‹น Node์˜ ์ •๋ณด๋กœ ๋ณ€๊ฒฝ๋œ๋‹ค.

์ธ์Šคํ„ด์Šค ์ƒ์„ธ

ํ•ด๋‹น Instance์˜ ์ƒ์„ธ ์ •๋ณด๋ฅผ ์ œ๊ณตํ•ฉ๋‹ˆ๋‹ค. flow005

ํ•„๋“œ์„ค๋ช…
Job IdBatch Instance Job Id
์ƒ์„ฑ๋œ ์‹œ๊ฐ„Instance๊ฐ€ ์ƒ์„ฑ๋œ ์‹œ๊ฐ„
์‹œ์ž‘ ์‹œ๊ฐ„Instance๊ฐ€ ์‹œ์ž‘๋œ ์‹œ๊ฐ„
์ข…๋ฃŒ ์‹œ๊ฐ„Instance๊ฐ€ ์ข…๋ฃŒ๋œ ์‹œ๊ฐ„
์ƒ์„ฑ์ž์ƒ์„ฑ์ž
์ธ์Šคํ„ด์Šค ์ƒํƒœ์ƒํƒœ (Running, Suspended, Killed, Succeeded)
DHP ์ฝ˜์†”ํ•ด๋‹น instance์˜ DHP ์ฝ˜์†”๋กœ ์ด๋™ํ•œ๋‹ค.

์ธ์Šคํ„ด์Šค ํŒŒ๋ผ๋ฏธํ„ฐ

ํ•ด๋‹น Instance Job ์‹คํ–‰ ์‹œ ์‚ฌ์šฉ๋œ Parameter ์ •๋ณด๋ฅผ ์ œ๊ณตํ•ฉ๋‹ˆ๋‹ค. flow006

์ธ์Šคํ„ด์Šค ๋กœ๊ทธ

ํ•ด๋‹น Instance Job ์‹คํ–‰ ์‹œ ๋ฐœ์ƒํ•œ Log๋ฅผ ์ œ๊ณตํ•ฉ๋‹ˆ๋‹ค. flow007