flow

flow

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

workflowinstance001

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

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

workflowinstance002

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

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

โ‘ก Job Id ํด๋ฆญ ์‹œ ํ•ด๋‹น Instance์˜ ์ƒ์„ธํ™”๋ฉด์œผ๋กœ ์ด๋™ํ•œ๋‹ค.

์Šค์ผ€์ค„ ์ธ์Šคํ„ด์Šค ๋ชฉ๋ก

workflowinstance003

โ‘  ์Šค์ผ€์ค„ ์‹คํ–‰ ์ด๋ ฅ ์กฐ๊ฑด ๊ทธ๋Œ€๋กœ ์žฌ์‹คํ–‰ / ์ผ์‹œ์ •์ง€ / ์žฌ๊ฐœ / ์ •์ง€ action ๋ฒ„ํŠผ

โ‘ก ์Šค์ผ€์ค„ ์‹คํ–‰ ์กฐ๊ฑด ๋ฐ ์ •๋ณด (์ธ์Šคํ„ด์Šค ๊ฐœ์ˆ˜, ์‹œ์ž‘ ์‹œ๊ฐ„, ์ข…๋ฃŒ์‹œ๊ฐ„, ์‹คํ–‰ ์ฃผ๊ธฐ, ์‹œ๊ฐ„๋Œ€, ์ตœ์ข…์ˆ˜์ •์‹œ๊ฐ„)

โ‘ข ํ•ด๋‹น Schedule์—์„œ ๋ฐœ์ƒํ•œJob instance ๋ชฉ๋ก

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

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

workflowinstance004

โ‘  โ€˜๋’ค๋กœ๊ฐ€๊ธฐโ€™ ๋ฒ„ํŠผ ํด๋ฆญํ•˜์—ฌ ์ธ์Šคํ„ด์Šค ๋ชฉ๋ก์œผ๋กœ ๋ณต๊ท€

โ‘ก ์ธ์Šคํ„ด์Šค ์ƒ์„ธ ํ™”๋ฉด์—์„œ ์ œ๊ณตํ•˜๋Š” ์ •๋ณด(ํ๋ฆ„/์ƒ์„ธ/ํŒŒ๋ผ๋ฏธํ„ฐ/๋กœ๊ทธ)

โ‘ข โ€˜ํ๋ฆ„โ€™ํƒญ์—์„œ Nodeํด๋ฆญ ์‹œ ํ•ด๋‹น Log๋ฅผ ์ œ๊ณต(INFO/STD/ERR)

โ‘ฃ Node์„ ํƒ์— ๋”ฐ๋ผ ํ•ด๋‹น Node์˜ ์ •๋ณด๋กœ ๋ณ€๊ฒฝ๋œ๋‹ค.

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

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

workflowinstance005

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

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

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

workflowinstance006

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

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

workflowinstance007