python

Definition

python 코드를 작성하여 실행하는 노드이다. property 패널 "8.source"에 python 코드를 입력한다. Source Editor 버튼("8.source" 우측 버튼) 클릭 시 Editor가 팝업되며 보다 큰 화면에서 코드를 작성할 수 있다.
좌측 [Flow구성]노드 중 [python]노드를 drag & drop 한다.

Set

[setting], [scheduler], [parameter] 설정은 [워크플로우 생성] > [설정]을 참고한다.

property

[Node Description] 작성 중인 노드명 입력

property 중 2~4 항목은 [연결관리]에 등록된 원격서버 정보 선택시 자동으로 입력되며, 원하는 서버목록이 없을 경우 [설정] > [원격서버관리]에서 필요서버를 먼저 등록한다.

1. appName : appName 입력
2. python 실행 IP : IP주소 및 PORT
   • IP주소 : 원격서버 접속 IP
   • PORT : 원격서버 접속 PORT
3. user : 원격 서버 사용자 아이디
4. password : 원격 서버 사용자 패스워드
5. 원격서버 ID : [설정] > [원격서버관리]에 저장된 서버 ID
6. 원격서버명 : [설정] > [원격서버관리]에 저장된 서버명
7. sourcepath : 브라우저를 통해 원격서버에 저장된 소스선택 후 불러오기 기능
8. source : 실행할 python 코드 입력
9. argument : 인수 설정
10. forceOK : 실패 시 강제 OK 처리 여부

Example

원격서버에 저장된 csv 파일을 읽어 txt 파일로 생성하는 파이선 코드 예제이다. 수집서버로 전달되는 원천데이터를 python으로 전처리하는 업무가 있을 경우 적용 가능하다.

1. hdfsToServer 노드를 사용해서 원격지 서버로 csv파일을 옮긴다.

• /home/dpcore/AIR_HOUR_2019_3.csv

2. 연결관리에서 원격서버를 선택한다.

3. 8.source 옵션에 아래와 같이 입력한다.

import csv, sys

sys.stdout = open('output_air_hour2019.txt','w')

with open('/home/dpcore/AIR_HOUR_2019_3.csv','r') as file:

reader = csv.reader(file)

for record in reader:

print(record)

4. 저장 및 실행 후 원격서버에 output_air_hour2019.txt 파일이 생성되었다.