¶ Nifi 예제
¶ NiFi 사용 가이드
- 프로세서/서비스 종류 및 사용법
https://nifi.apache.org/docs.html
¶ CSV to JSON 예제
Dataflow template는 첨부파일 참고
(https://redmine.encore.rnd/attachments/download/1327/csv-to-json-example.xml)
¶ 1. GetFile Processor 구성
¶ 1.1. GetFile Processor 생성
¶ 1.2. GetFile Processor 설정
¶ 2. ConvertRecord Processor 구성
¶ 2.1. ConvertRecord Processor 생성
¶ 2.2. Controller service 구성
1) Avro Schema Registry 구성
(이미지 없음: clipboard-202210041047-zxnaw.png)
{
"type":"record",
"name":"demo_schema",
"fields":
[
{"name": "name", "type": "string"},
{"name": "age", "type": "int"}
]
}
2) Json Tree Reader 구성
3) CSV RecordSet Writer 구성
4) 전체 Controller service 실행
¶ 2.3. ConvertRecord Processor 설정
¶ 3. UpdateAttribute Processor 구성
¶ 3.1. UpdateAttribute Processor 생성
¶ 3.2. UpdateAttribute Processor 설정
${filename:substringBeforeLast('.')}.csv
¶ 4. Putfile Processor 구성
¶ 4.1. Putfile Processor 생성
¶ 4.1. Putfile Processor 설정
¶ 5. DataFlow 실행
