flow
flow
์ํฌํ๋ก์ฐ ๋ชฉ๋ก์์ [์ธ์คํด์ค ๋ชฉ๋ก]์ ์ ํํ๋ฉด ์ธ์คํด์ค ์์ ๋ชฉ๋ก์ ํ์ธํ ์ ์๋ค.
๋ฐฐ์น ์ธ์คํด์ค ๋ชฉ๋ก
ํด๋น ์ธ์คํด์ค ๋ชฉ๋ก์ ์ ํํ ํ ์ธ์คํด์ค(์์ ) ์ ๋ณด๋ฅผ ํ์ธํ๋ค.
โ ํด๋น ์ํฌํ๋ก์ฐ์์ ๋ฐ์ํ Batch job instance ๋ชฉ๋ก์ ํ์ํ๋ค.
ํ๋ | ์ค๋ช |
---|---|
ํด๋ฌ์คํฐ | ํด๋น batch job์ด ์คํ๋ cluster ์ ๋ณด |
Job ID | ์ํฌํ๋ก์ฐ๊ฐ ์คํ๋ ๋ ์์ฑ๋ Job ID |
์ํฌํ๋ก์ฐ๋ช | ์ํฌํ๋ก์ฐ ์ด๋ฆ |
์์ ์๊ฐ | Instance๊ฐ ์์๋ ์๊ฐ |
์ข ๋ฃ ์๊ฐ | Instance๊ฐ ์ข ๋ฃ๋ ์๊ฐ |
์ํ | ์ํ (Running, Suspended, Killed, Succeeded) |
Action | ํด๋น Instance๋ฅผ ์ํ์ ๋ฐ๋ผ ์ ์ดํ ์ ์๋ค. (์คํ, ์ฌ๊ฐ, ์ผ์์ ์ง, ์ข ๋ฃ) |
๊ฐ Instance์ ์ํ์ ๋ฐ๋ผ ๊ทธ ์์ ์ ์ฌ์ฉ ๊ฐ๋ฅํ ๋ฉ๋ด๊ฐ ํ์ฑํ ๋๋ค. |
โก Job Id ํด๋ฆญ ์ ํด๋น Instance์ ์์ธํ๋ฉด์ผ๋ก ์ด๋ํ๋ค.
์ค์ผ์ค ์ธ์คํด์ค ๋ชฉ๋ก
โ ์ค์ผ์ค ์คํ ์ด๋ ฅ ์กฐ๊ฑด ๊ทธ๋๋ก ์ฌ์คํ / ์ผ์์ ์ง / ์ฌ๊ฐ / ์ ์ง 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์ ์ํ์ ๋ฐ๋ผ ๊ทธ ์์ ์ ์ฌ์ฉ ๊ฐ๋ฅํ ๋ฉ๋ด๊ฐ ํ์ฑํ ๋๋ค. |
์ธ์คํด์ค ํ๋ฆ
โ โ๋ค๋ก๊ฐ๊ธฐโ ๋ฒํผ ํด๋ฆญํ์ฌ ์ธ์คํด์ค ๋ชฉ๋ก์ผ๋ก ๋ณต๊ท
โก ์ธ์คํด์ค ์์ธ ํ๋ฉด์์ ์ ๊ณตํ๋ ์ ๋ณด(ํ๋ฆ/์์ธ/ํ๋ผ๋ฏธํฐ/๋ก๊ทธ)
โข โํ๋ฆโํญ์์ Nodeํด๋ฆญ ์ ํด๋น Log๋ฅผ ์ ๊ณต(INFO/STD/ERR)
โฃ Node์ ํ์ ๋ฐ๋ผ ํด๋น Node์ ์ ๋ณด๋ก ๋ณ๊ฒฝ๋๋ค.
์ธ์คํด์ค ์์ธ
ํด๋น Instance์ ์์ธ ์ ๋ณด๋ฅผ ์ ๊ณตํ๋ค.
ํ๋ | ์ค๋ช |
---|---|
Job Id | Batch Instance Job Id |
์์ฑ๋ ์๊ฐ | Instance๊ฐ ์์ฑ๋ ์๊ฐ |
์์ ์๊ฐ | Instance๊ฐ ์์๋ ์๊ฐ |
์ข ๋ฃ ์๊ฐ | Instance๊ฐ ์ข ๋ฃ๋ ์๊ฐ |
์์ฑ์ | ์์ฑ์ |
์ธ์คํด์ค ์ํ | ์ํ (Running, Suspended, Killed, Succeeded) |
DHP ์ฝ์ | ํด๋น instance์ DHP ์ฝ์๋ก ์ด๋ํ๋ค. |
์ธ์คํด์ค ํ๋ผ๋ฏธํฐ
ํด๋น Instance Job ์คํ ์ ์ฌ์ฉ๋ Parameter ์ ๋ณด๋ฅผ ์ ๊ณตํ๋ค.
์ธ์คํด์ค ๋ก๊ทธ
ํด๋น Instance Job ์คํ ์ ๋ฐ์ํ Log๋ฅผ ์ ๊ณตํ๋ค.