serverToHdfs

Definition

์„œ๋ฒ„์— ์œ„์น˜ํ•œ ํŒŒ์ผ์„ HDFS๋กœ ๋ณต์‚ฌํ•˜๋Š” ๋…ธ๋“œ์ด๋‹ค. [Flow๊ตฌ์„ฑ]๋…ธ๋“œ ์ค‘ [serverToHdfs]๋…ธ๋“œ๋ฅผ drag & drop ํ•œ ํ›„ Property ํ•ญ๋ชฉ์„ ์ž…๋ ฅํ•œ๋‹ค.

Set

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

property

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

flow019

  1. ์›๊ฒฉ ์„œ๋ฒ„ IP : IP์ฃผ์†Œ์™€ Port์ •๋ณด๋ฅผ ์ž…๋ ฅํ•œ๋‹ค. [์—ฐ๊ฒฐ๊ด€๋ฆฌ] ์ œ๋ชฉ ์šฐ์ธก์˜ [๋ชฉ๋ก์—ด๊ธฐ] ๋ฒ„ํŠผ์„ ๋ˆŒ๋Ÿฌ ๊ธฐ์ €์žฅ๋œ ์›๊ฒฉ์„œ๋ฒ„ ์ •๋ณด๋ฅผ ์„ ํƒํ•  ์ˆ˜ ์žˆ๋‹ค.
    • IP์ฃผ์†Œ : ์„œ๋ฒ„ IP
    • PORT : ์„œ๋ฒ„ PORT
  2. sourceFolder : source ํŒŒ์ผ ๊ฒฝ๋กœ ec) /home/dpcore
  3. sourceFile : source ํŒŒ์ผ ๋ช… ex) target.csv
  4. user : SSH User ID
  5. password : SSH User Password
  6. hdfsFilePath : ์ €์žฅํ•  HDFS ๊ฒฝ๋กœ ex) /tmp

Example

์›๊ฒฉ์„œ๋ฒ„ /home/dpcore ๊ฒฝ๋กœ์— ์œ„์น˜ํ•œ servertohdfs.csvํŒŒ์ผ์„ HDFS์— ์ ์žฌํ•˜๊ณ ์ž ํ•œ๋‹ค.

flow026

  1. ๋ชฉ๋ก์—ด๊ธฐ ๋ฒ„ํŠผ์„ ํ™œ์šฉํ•˜์—ฌ ์›๊ฒฉ์„œ๋ฒ„ ์ •๋ณด๋ฅผ ์„ ํƒํ•œ๋‹ค. ์„œ๋ฒ„์ •๋ณด๋ฅผ ์„ ํƒํ•˜๋ฉด [์›๊ฒฉ์„œ๋ฒ„IP], [user], [passwird]๊ฐ€ ์ž๋™ ์ž…๋ ฅ๋œ๋‹ค. ์›๊ฒฉ์„œ๋ฒ„ ๋“ฑ๋ก๋ฐฉ๋ฒ•์€ ๋งค๋‰ด์–ผ [์›๊ฒฉ์„œ๋ฒ„๊ด€๋ฆฌ]๋ฅผ ์ฐธ๊ณ ํ•œ๋‹ค.
  2. sourceFolder์— "/home/dpcore"๋ฅผ sourceFile์— "servertohdfs.csv"๋ฅผ ์ž…๋ ฅํ•œ๋‹ค.
  3. hdfsFilePath ์ •๋ณด๋ฅผ ์ž…๋ ฅํ•œ๋‹ค. [๋ธŒ๋ผ์šฐ์ €] > [HDFS๋ธŒ๋ผ์šฐ์ €]๋กœ ์ด๋™ํ•˜์—ฌ ํด๋Ÿฌ์Šคํ„ฐ์™€ ์ €์žฅ๊ฒฝ๋กœ๋ฅผ ์„ ํƒํ•œ ํ›„ ์šฐ์ธก ์ƒ๋‹จ์˜ [HDFS ๊ฒฝ๋กœ ๋ณต์‚ฌ]๋ฅผ ์„ ํƒํ•œ๋‹ค. HDFS๊ฒฝ๋กœ๊ฐ€ ์ž๋™ ๋ณต์‚ฌ๋œ๋‹ค.

flow027

flow028

์›Œํฌํ”Œ๋กœ์šฐ ์‹คํ–‰๊ฒฐ๊ณผ๋Š” ์•„๋ž˜์™€ ๊ฐ™๋‹ค.

flow029