지난 시간동안 우리는 하둡을 설치와 예제 실현을 통해 정상적으로 인스톨됨을 확인한 바가 있다.
2018/02/10 - [프로그래밍발전소 ♫/Hadoop발전소♫] - OSX에 Hadoop 설치하기 (ver 1)
2018/02/11 - [분류 전체보기] - OSX에 Hadoop 설치하기 (ver 2)
이번에는 하둡용 어플을 만들어보기전에 우리가 지지고볶고 해야될 데이터가 필요하기 때문에
데이터를 다운받아보도록합시다.
stat-computing.org에서 Download the Data를 클릭하시고~
그럼 1987~2008까지의 데이터들을 다운받아야겠죠? 허나 수기로 일일이 다운받는다면..
무슨 프로그래밍하는 사람의로써의 의미가 있겠습니까..
저번에 써먹었던 wget 명령어를 활용해 쉘을 만들어봅시다.
1 #!/bin/sh
2
3 for((i=1987; i<=2009;i++))
4 do
5 wget http://stat-computing.org/dataexpo/2009/${i}.csv.bz2
6 done
~
~
~
~
위에같이 for문으로 1987~2009까지 지정해주고 wget메소드를 활용하고 중간에 파라미터를 집어넣어서 저 쉘을 실행시키면
설정해준 기간까지의 데이터를 다운받게끔 진행합시다. 실행하기전에 chmod 777로 실행권한을 줘야합니다.
==================================================================================================
~
LoganLeeui-MacBook-Pro:hadoop Logan$ ./download.sh
--2018-02-11 14:54:05-- http://stat-computing.org/dataexpo/2009/1987.csv.bz2
Resolving stat-computing.org... 54.231.168.223
Connecting to stat-computing.org|54.231.168.223|:80... connected.
HTTP request sent, awaiting response... 200 OK
Length: 12652442 (12M) [application/x-bzip2]
Saving to: '1987.csv.bz2'
1987.csv.bz2 100%[============================>] 12.07M 18.1MB/s in 0.7s
2018-02-11 14:54:07 (18.1 MB/s) - '1987.csv.bz2' saved [12652442/12652442]
--2018-02-11 14:54:07-- http://stat-computing.org/dataexpo/2009/1988.csv.bz2
Resolving stat-computing.org... 54.231.168.223
Connecting to stat-computing.org|54.231.168.223|:80... connected.
HTTP request sent, awaiting response... 200 OK
Length: 49499025 (47M) [application/x-bzip2]
Saving to: '1988.csv.bz2'
1988.csv.bz2 100%[============================>] 47.21M 305KB/s in 69s
2018-02-11 14:55:16 (701 KB/s) - '1988.csv.bz2' saved [49499025/49499025]
--2018-02-11 14:55:16-- http://stat-computing.org/dataexpo/2009/1989.csv.bz2
Resolving stat-computing.org... 52.218.200.91
Connecting to stat-computing.org|52.218.200.91|:80... connected.
HTTP request sent, awaiting response... 200 OK
Length: 49202298 (47M) [application/x-bzip2]
Saving to: '1989.csv.bz2'
1989.csv.bz2 100%[============================>] 46.92M 712KB/s in 32s
2018-02-11 14:55:49 (1.45 MB/s) - '1989.csv.bz2' saved [49202298/49202298]
--2018-02-11 14:55:49-- http://stat-computing.org/dataexpo/2009/1990.csv.bz2
Resolving stat-computing.org... 52.218.208.107
Connecting to stat-computing.org|52.218.208.107|:80... connected.
HTTP request sent, awaiting response... 200 OK
Length: 52041322 (50M) [application/x-bzip2]
Saving to: '1990.csv.bz2'
1990.csv.bz2 100%[============================>] 49.63M 1.79MB/s in 21s
2018-02-11 14:56:11 (2.36 MB/s) - '1990.csv.bz2' saved [52041322/52041322]
--2018-02-11 14:56:11-- http://stat-computing.org/dataexpo/2009/1991.csv.bz2
Resolving stat-computing.org... 54.231.168.215
Connecting to stat-computing.org|54.231.168.215|:80... connected.
HTTP request sent, awaiting response... 200 OK
Length: 49877448 (48M) [application/x-bzip2]
Saving to: '1991.csv.bz2'
1991.csv.bz2 100%[============================>] 47.57M 555KB/s in 71s
2018-02-11 14:57:23 (686 KB/s) - '1991.csv.bz2' saved [49877448/49877448]
--2018-02-11 14:57:23-- http://stat-computing.org/dataexpo/2009/1992.csv.bz2
Resolving stat-computing.org... 52.218.201.35
Connecting to stat-computing.org|52.218.201.35|:80... connected.
HTTP request sent, awaiting response... 200 OK
Length: 50040946 (48M) [application/x-bzip2]
Saving to: '1992.csv.bz2'
1992.csv.bz2 100%[============================>] 47.72M 1.67MB/s in 23s
2018-02-11 14:57:46 (2.08 MB/s) - '1992.csv.bz2' saved [50040946/50040946]
--2018-02-11 14:57:46-- http://stat-computing.org/dataexpo/2009/1993.csv.bz2
Resolving stat-computing.org... 54.231.168.167
Connecting to stat-computing.org|54.231.168.167|:80... connected.
HTTP request sent, awaiting response... 200 OK
Length: 50111774 (48M) [application/x-bzip2]
Saving to: '1993.csv.bz2'
1993.csv.bz2 100%[============================>] 47.79M 716KB/s in 68s
2018-02-11 14:58:55 (722 KB/s) - '1993.csv.bz2' saved [50111774/50111774]
--2018-02-11 14:58:55-- http://stat-computing.org/dataexpo/2009/1994.csv.bz2
Resolving stat-computing.org... 52.218.193.179
Connecting to stat-computing.org|52.218.193.179|:80... connected.
HTTP request sent, awaiting response... 200 OK
Length: 51123887 (49M) [application/x-bzip2]
Saving to: '1994.csv.bz2'
1994.csv.bz2 100%[============================>] 48.75M 761KB/s in 27s
2018-02-11 14:59:22 (1.80 MB/s) - '1994.csv.bz2' saved [51123887/51123887]
--2018-02-11 14:59:23-- http://stat-computing.org/dataexpo/2009/1995.csv.bz2
Resolving stat-computing.org... 54.231.184.167
Connecting to stat-computing.org|54.231.184.167|:80... connected.
HTTP request sent, awaiting response... 200 OK
Length: 74881752 (71M) [application/x-bzip2]
Saving to: '1995.csv.bz2'
1995.csv.bz2 100%[============================>] 71.41M 938KB/s in 87s
2018-02-11 15:00:51 (839 KB/s) - '1995.csv.bz2' saved [74881752/74881752]
--2018-02-11 15:00:51-- http://stat-computing.org/dataexpo/2009/1996.csv.bz2
Resolving stat-computing.org... 52.218.200.99
Connecting to stat-computing.org|52.218.200.99|:80... connected.
HTTP request sent, awaiting response... 200 OK
Length: 75887707 (72M) [application/x-bzip2]
Saving to: '1996.csv.bz2'
1996.csv.bz2 100%[============================>] 72.37M 2.15MB/s in 56s
2018-02-11 15:01:48 (1.28 MB/s) - '1996.csv.bz2' saved [75887707/75887707]
--2018-02-11 15:01:48-- http://stat-computing.org/dataexpo/2009/1997.csv.bz2
Resolving stat-computing.org... 52.218.192.235
Connecting to stat-computing.org|52.218.192.235|:80... connected.
HTTP request sent, awaiting response... 200 OK
Length: 76705687 (73M) [application/x-bzip2]
Saving to: '1997.csv.bz2'
1997.csv.bz2 100%[============================>] 73.15M 976KB/s in 39s
2018-02-11 15:02:27 (1.87 MB/s) - '1997.csv.bz2' saved [76705687/76705687]
--2018-02-11 15:02:27-- http://stat-computing.org/dataexpo/2009/1998.csv.bz2
Resolving stat-computing.org... 52.218.128.15
Connecting to stat-computing.org|52.218.128.15|:80... connected.
HTTP request sent, awaiting response... 200 OK
Length: 76683506 (73M) [application/x-bzip2]
Saving to: '1998.csv.bz2'
1998.csv.bz2 100%[============================>] 73.13M 249KB/s in 2m 8s
2018-02-11 15:04:36 (585 KB/s) - '1998.csv.bz2' saved [76683506/76683506]
--2018-02-11 15:04:36-- http://stat-computing.org/dataexpo/2009/1999.csv.bz2
Resolving stat-computing.org... 52.218.193.219
Connecting to stat-computing.org|52.218.193.219|:80... connected.
HTTP request sent, awaiting response... 200 OK
Length: 79449438 (76M) [application/x-bzip2]
Saving to: '1999.csv.bz2'
1999.csv.bz2 100%[============================>] 75.77M 1.59MB/s in 53s
2018-02-11 15:05:30 (1.43 MB/s) - '1999.csv.bz2' saved [79449438/79449438]
--2018-02-11 15:05:30-- http://stat-computing.org/dataexpo/2009/2000.csv.bz2
Resolving stat-computing.org... 52.218.192.211
Connecting to stat-computing.org|52.218.192.211|:80... connected.
HTTP request sent, awaiting response... 200 OK
Length: 82537924 (79M) [application/x-bzip2]
Saving to: '2000.csv.bz2'
2000.csv.bz2 100%[============================>] 78.71M 2.95MB/s in 62s
2018-02-11 15:06:32 (1.28 MB/s) - '2000.csv.bz2' saved [82537924/82537924]
--2018-02-11 15:06:32-- http://stat-computing.org/dataexpo/2009/2001.csv.bz2
Resolving stat-computing.org... 52.218.144.59
Connecting to stat-computing.org|52.218.144.59|:80... connected.
HTTP request sent, awaiting response... 200 OK
Length: 83478700 (80M) [application/x-bzip2]
Saving to: '2001.csv.bz2'
2001.csv.bz2 100%[============================>] 79.61M 539KB/s in 5m 14s
2018-02-11 15:11:47 (259 KB/s) - '2001.csv.bz2' saved [83478700/83478700]
--2018-02-11 15:11:47-- http://stat-computing.org/dataexpo/2009/2002.csv.bz2
Resolving stat-computing.org... 54.231.168.163
Connecting to stat-computing.org|54.231.168.163|:80... connected.
HTTP request sent, awaiting response... 200 OK
Length: 75907218 (72M) [application/x-bzip2]
Saving to: '2002.csv.bz2'
2002.csv.bz2 100%[============================>] 72.39M 778KB/s in 2m 12s
2018-02-11 15:14:00 (560 KB/s) - '2002.csv.bz2' saved [75907218/75907218]
--2018-02-11 15:14:00-- http://stat-computing.org/dataexpo/2009/2003.csv.bz2
Resolving stat-computing.org... 52.218.192.59
Connecting to stat-computing.org|52.218.192.59|:80... connected.
HTTP request sent, awaiting response... 200 OK
Length: 95326801 (91M) [application/x-bzip2]
Saving to: '2003.csv.bz2'
2003.csv.bz2 66%[==================> ] 60.82M 1.14MB/s eta 14s
// 보시는것과 같이 다운로드가 진행되고있음을 알 수 있습니다. 압축형식은 bz2 형식이네요/.
==================================================================================================
이제 압축을 풀어봅시다.
bzip2 -d *.bz2
LoganLeeui-MacBook-Pro:original Logan$ ls
1987.csv 1990.csv 1993.csv 1996.csv 1999.csv 2002.csv 2005.csv 2008.csv
1988.csv 1991.csv 1994.csv 1997.csv 2000.csv 2003.csv 2006.csv
1989.csv 1992.csv 1995.csv 1998.csv 2001.csv 2004.csv 2007.csv
일단 명령어를 실행하면 시간이 걸립니다.
터미널 텝을 열어 확인해본다면, 풀리고 있는 중이라는 걸 아실수있습니다.
==================================================================================================
head -n 10 1987.csv
Year,Month,DayofMonth,DayOfWeek,DepTime,CRSDepTime,ArrTime,CRSArrTime,UniqueCarrier,FlightNum,TailNum,ActualElapsedTime,CRSElapsedTime,AirTime,ArrDelay,DepDelay,Origin,Dest,Distance,TaxiIn,TaxiOut,Cancelled,CancellationCode,Diverted,CarrierDelay,WeatherDelay,NASDelay,SecurityDelay,LateAircraftDelay
1987,10,14,3,741,730,912,849,PS,1451,NA,91,79,NA,23,11,SAN,SFO,447,NA,NA,0,NA,0,NA,NA,NA,NA,NA
1987,10,15,4,729,730,903,849,PS,1451,NA,94,79,NA,14,-1,SAN,SFO,447,NA,NA,0,NA,0,NA,NA,NA,NA,NA
1987,10,17,6,741,730,918,849,PS,1451,NA,97,79,NA,29,11,SAN,SFO,447,NA,NA,0,NA,0,NA,NA,NA,NA,NA
1987,10,18,7,729,730,847,849,PS,1451,NA,78,79,NA,-2,-1,SAN,SFO,447,NA,NA,0,NA,0,NA,NA,NA,NA,NA
1987,10,19,1,749,730,922,849,PS,1451,NA,93,79,NA,33,19,SAN,SFO,447,NA,NA,0,NA,0,NA,NA,NA,NA,NA
1987,10,21,3,728,730,848,849,PS,1451,NA,80,79,NA,-1,-2,SAN,SFO,447,NA,NA,0,NA,0,NA,NA,NA,NA,NA
1987,10,22,4,728,730,852,849,PS,1451,NA,84,79,NA,3,-2,SAN,SFO,447,NA,NA,0,NA,0,NA,NA,NA,NA,NA
1987,10,23,5,731,730,902,849,PS,1451,NA,91,79,NA,13,1,SAN,SFO,447,NA,NA,0,NA,0,NA,NA,NA,NA,NA
1987,10,24,6,744,730,908,849,PS,1451,NA,84,79,NA,19,14,SAN,SFO,447,NA,NA,0,NA,0,NA,NA,NA,NA,NA
파일을 살펴보면 1줄에 각각의 데이터가 무엇을 의미하고있는지를 가지고 있습니다.
허나, 데이터 처리과정 중에 에러를 야기할 수 있는 사항이기 때문에 지우도록합시다.
==================================================================================================
1987~2008의 파일들을 만져야하니 커맨드 한줄로도 가능하긴합니다.
sed -e '1d' *.csv > *_modified.csv 처럼...(하지만 이렇게 진행한다면, 제대로 진행되지않습니다. 궁금하신분들은 직접한번!)
허나 추후에 재사용을 위해 쉘을 만들어줍니다.
1 #!/bin/sh
2
3 for((i=1987; i<=2008; i++))
4 do
5 sed -e '1d' ${i}.csv > ${i}_modi.csv
6 done
실행후에 디렉토리를 살펴봅시다.
==================================================================================================
ls
1987.csv 1991.csv 1995.csv 1999.csv 2003.csv 2007.csv
1987_modi.csv 1991_modi.csv 1995_modi.csv 1999_modi.csv 2003_modi.csv 2007_modi.csv
1988.csv 1992.csv 1996.csv 2000.csv 2004.csv 2008.csv
1988_modi.csv 1992_modi.csv 1996_modi.csv 2000_modi.csv 2004_modi.csv 2008_modi.csv
1989.csv 1993.csv 1997.csv 2001.csv 2005.csv sed.sh
1989_modi.csv 1993_modi.csv 1997_modi.csv 2001_modi.csv 2005_modi.csv
1990.csv 1994.csv 1998.csv 2002.csv 2006.csv
1990_modi.csv 1994_modi.csv 1998_modi.csv 2002_modi.csv 2006_modi.csv
짜잔,
==================================================================================================
이제 원본유지를 위해 나누어줍시다.
ls
1987_modi.csv 1991_modi.csv 1995_modi.csv 1999_modi.csv 2003_modi.csv 2007_modi.csv
1988_modi.csv 1992_modi.csv 1996_modi.csv 2000_modi.csv 2004_modi.csv 2008_modi.csv
1989_modi.csv 1993_modi.csv 1997_modi.csv 2001_modi.csv 2005_modi.csv
1990_modi.csv 1994_modi.csv 1998_modi.csv 2002_modi.csv 2006_modi.csv
==================================================================================================
hdfs에 데이터를 집어넣을 폴더를 만들어줍니다.
==================================================================================================
fs -put ~/dataexpo/original/*.csv input
LoganLeeui-MacBook-Pro:~ Logan$ hadoop fs -ls
Found 4 items
drwxr-xr-x - Logan supergroup 0 2018-02-10 19:52 /user/Logan/conf
drwxr-xr-x - Logan supergroup 0 2018-02-14 03:07 /user/Logan/input
drwxr-xr-x - Logan supergroup 0 2018-02-10 19:52 /user/Logan/output_
drwxr-xr-x - Logan supergroup 0 2018-02-11 09:38 /user/Logan/output_2
명령어로 hdfs에 업로드해봅시다.
==================================================================================================
hadoop fs -lsr
drwxr-xr-x - Logan supergroup 0 2018-02-15 15:01 /user/Logan/input
-rw-r--r-- 1 Logan supergroup 127162642 2018-02-15 15:00 /user/Logan/input/1987_modi.csv
-rw-r--r-- 1 Logan supergroup 501039172 2018-02-15 15:00 /user/Logan/input/1988_modi.csv
-rw-r--r-- 1 Logan supergroup 486518521 2018-02-15 15:00 /user/Logan/input/1989_modi.csv
-rw-r--r-- 1 Logan supergroup 509194387 2018-02-15 15:00 /user/Logan/input/1990_modi.csv
-rw-r--r-- 1 Logan supergroup 491209793 2018-02-15 15:00 /user/Logan/input/1991_modi.csv
-rw-r--r-- 1 Logan supergroup 492313431 2018-02-15 15:00 /user/Logan/input/1992_modi.csv
-rw-r--r-- 1 Logan supergroup 490753352 2018-02-15 15:00 /user/Logan/input/1993_modi.csv
-rw-r--r-- 1 Logan supergroup 501558365 2018-02-15 15:00 /user/Logan/input/1994_modi.csv
-rw-r--r-- 1 Logan supergroup 530751268 2018-02-15 15:00 /user/Logan/input/1995_modi.csv
-rw-r--r-- 1 Logan supergroup 533922063 2018-02-15 15:00 /user/Logan/input/1996_modi.csv
-rw-r--r-- 1 Logan supergroup 540347561 2018-02-15 15:00 /user/Logan/input/1997_modi.csv
-rw-r--r-- 1 Logan supergroup 538432575 2018-02-15 15:00 /user/Logan/input/1998_modi.csv
-rw-r--r-- 1 Logan supergroup 552925722 2018-02-15 15:00 /user/Logan/input/1999_modi.csv
-rw-r--r-- 1 Logan supergroup 570151313 2018-02-15 15:00 /user/Logan/input/2000_modi.csv
-rw-r--r-- 1 Logan supergroup 600411162 2018-02-15 15:00 /user/Logan/input/2001_modi.csv
-rw-r--r-- 1 Logan supergroup 530506713 2018-02-15 15:01 /user/Logan/input/2002_modi.csv
-rw-r--r-- 1 Logan supergroup 626744942 2018-02-15 15:01 /user/Logan/input/2003_modi.csv
-rw-r--r-- 1 Logan supergroup 669878813 2018-02-15 15:01 /user/Logan/input/2004_modi.csv
-rw-r--r-- 1 Logan supergroup 671026965 2018-02-15 15:01 /user/Logan/input/2005_modi.csv
-rw-r--r-- 1 Logan supergroup 672067796 2018-02-15 15:01 /user/Logan/input/2006_modi.csv
-rw-r--r-- 1 Logan supergroup 702877893 2018-02-15 15:01 /user/Logan/input/2007_modi.csv
-rw-r--r-- 1 Logan supergroup 689413044 2018-02-15 15:01 /user/Logan/input/2008_modi.csv
-lsr로 확인해보고 이상이 없으면 클리어!
RECENT COMMENT