hdfsToIcos

Definition

HDFS ํŒŒ์ผ/ํด๋”๋ฅผ ICOS์— ๋ณต์‚ฌ ํ•˜๋Š” ๋…ธ๋“œ์ด๋‹ค. ์ขŒ์ธก [Flow๊ตฌ์„ฑ]๋…ธ๋“œ ์ค‘ [hdfsToIcos]๋…ธ๋“œ๋ฅผ drag & drop ํ•œ ํ›„ Property ํ•ญ๋ชฉ์„ ์ž…๋ ฅํ•œ๋‹ค. Property ํŒจ๋„์˜ [๋”๋ณด๊ธฐ+] ๋ฒ„ํŠผ์„ ๋ˆ„๋ฅด๋ฉด ์ž…๋ ฅ๊ฐ€๋Šฅํ•œ ์ „์ฒด Property ํ•ญ๋ชฉ์„ ๋ณผ ์ˆ˜ ์žˆ๋‹ค.

Set

[setting], [scheduler], [parameter] ์„ค์ •์€ [์›Œํฌํ”Œ๋กœ์šฐ ์ƒ์„ฑ] > [์„ค์ •]์„ ์ฐธ๊ณ ํ•œ๋‹ค.

property

[Node Description] ์ž‘์„ฑ ์ค‘์ธ ๋…ธ๋“œ๋ช… ์ž…๋ ฅ

flow006

  1. hdfsํŒŒ์ผ๊ฒฝ๋กœ(๋ถˆ๋Ÿฌ์˜ค๊ธฐ) : ์ด๋™ ๋Œ€์ƒ ํŒŒ์ผ์˜ HDFS ๊ฒฝ๋กœ
  2. ICOS ํŒŒ์ผ๊ฒฝ๋กœ (์ €์žฅ๊ฒฝ๋กœ) : ์ €์žฅํ•  ICOS ํŒŒ์ผ๊ฒฝ๋กœ ์„ ํƒ
  3. ETL ๊ฒฐ๊ณผํŒŒ์ผ ์—ฌ๋ถ€ : ETL ๋…ธ๋“œ๋ฅผ ํ†ตํ•ด ์ƒ์„ฑ๋œ ๋ชจ๋“  ํŒŒ์ผ์„ ๋Œ€์ƒ์œผ๋กœ ํ• ์ง€ ์—ฌ๋ถ€
    • HDFS ํŒŒ์ผ์„ ์•„๋ž˜์™€ ๊ฐ™์ด ์ž…๋ ฅํ•œ๊ฒฝ์šฐ, ํ•˜์œ„ part*ํ•ด๋‹นํŒŒ์ผ ๋ชจ๋‘ ์ด๋™
    • hdfs://OOO.OOO.OOO.OOO:8020/user/sample_user/source_data/
  4. Credential : ICOS ์—‘์„ธ์Šค ์ •๋ณด (ICOS ํŒŒ์ผ๊ฒฝ๋กœ ์„ ํƒ์‹œ ์ž๋™ ์„ค์ •๋จ)

Example

hdfs์— ์ €์žฅ๋œ csvํŒŒ์ผ์„ icos๋กœ ์ด๋™ํ•˜๋Š” ์˜ˆ์ œ์ด๋‹ค.

  1. setting ํŒจ๋„์—์„œ ์›Œํฌํ”Œ๋กœ์šฐ ์‹คํ–‰ ํด๋Ÿฌ์Šคํ„ฐ๋ฅผ ์„ ํƒํ•œ๋‹ค.
  2. property ํŒจ๋„์—์„œ hdfs, icos ๊ฒฝ๋กœ๋ฅผ ์ง€์ •ํ•œ๋‹ค. ETL ๊ฒฐ๊ณผํŒŒ์ผ์—ฌ๋ถ€๋Š” FALSE๋กœ ์„ ํƒํ•œ๋‹ค. icos ์ €์žฅ๊ฒฝ๋กœ๋ฅผ ์ง€์ •ํ•˜๋ฉด 4.credential ํ•ญ๋ชฉ์€ ์ž๋™ ์„ค์ •๋œ๋‹ค.
  • 1.HDFS ํŒŒ์ผ ๊ฒฝ๋กœ(๋ถˆ๋Ÿฌ์˜ค๊ธฐ)
    flow065

  • 2.ICOS ํŒŒ์ผ ๊ฒฝ๋กœ(์ €์žฅ๊ฒฝ๋กœ)
    flow066

  • property ์„ค์ •๋‚ด์—ญ
    flow067

  1. ์›Œํฌํ”Œ๋กœ์šฐ ์ €์žฅ ๋ฐ ์‹คํ–‰ ํ›„ ICOS ์Šคํ† ๋ฆฌ์ง€์— csvํŒŒ์ผ์ด ์ €์žฅ๋๋‹ค.
    flow068

Troubleshooting

  1. ICOS ๋ธŒ๋ผ์šฐ์ €์—์„œ ์Šคํ† ๋ฆฌ์ง€ ๋ชฉ๋ก์ด ์กฐํšŒ๋˜์ง€ ์•Š์„ ๊ฒฝ์šฐ

flow069

  • dpcore > core-module-common config์—์„œ [icos.config.use=false] ์ธ์ง€ ํ™•์ธ
  • [icos.config.use=true]๋กœ ์„ค์ •์‹œ ICOS ๋ธŒ๋ผ์šฐ์ €์—์„œ ์Šคํ† ๋ฆฌ์ง€ ๋ชฉ๋ก ํ™•์ธ ๊ฐ€๋Šฅ
  • false ์„ค์ •์‹œ true๋กœ ๋ณ€๊ฒฝ ํ›„ core-module-common ๋ชจ๋“ˆ ์žฌ๋ฐฐํฌ ํ•„์š”
  1. ICOS ๋ธŒ๋ผ์šฐ์ €์—์„œ ์Šคํ† ๋ฆฌ์ง€ ๋ชฉ๋ก์ด ์กฐํšŒ๋˜์ง€ ์•Š์„ ๊ฒฝ์šฐ

flow070