NiFi JSON 파일 요청 수락

3286 단어 NiFi
NiFi를 통해 REST 고객이 보낸 JSON 파일을 받는 방법
이 예에서 접수 후 JSON을 분석하여 조건 지점을 진행한다.
HTTP 컨텍스트 준비
화면 오른쪽 상단에 있는 Controller Settings 를 클릭하십시오.

오른쪽 상단의 + 단추를 누르고 StandardHttpContextMap 추가를 선택하십시오.

그게 다야.웹 서버를 구축할 필요가 없습니다.
HTTP 요구 사항을 작성하는 청중
Processor 아이콘을 Canvas에 끌어다 놓고HandleHttpRequest를 선택하십시오.

Property는 다음과 같이 설정합니다.

Listening Port: 고객이 액세스할 포트를 확인하고 입력
HTTP Context Map: 방금 만든 HTTP 컨텍스트 선택
Allowed Paths: 클라이언트가 액세스할 수 있는 URL은 http:/: < 방금 지정한 포트 번호 >/< 여기에서 지정한 경로 >여러 개를 지정할 수 있습니다.
Allow GET,PPOST... : Accept의 HTTP 메서드를 Trust로 설정합니다.
Client Authentication: (추후 추가)
JSON Para 만들기
받은 JSON을 지우고 NiFi의 attribute에 저장합니다.
아까와 같이 Processor를 Canvas에 끌어다 놓고 EvaluateJsonPath를 선택하십시오.

Destination:flowfile-attribute는 JSON의 값을 NiFi의 Attribute에 저장합니다.Attribute 추가 필요(후술)
굵은 글꼴을 이미지로 설정하고 오른쪽 위 모서리의 +(New Property)를 클릭합니다.
그림에서 attribute1, attribute2는 Attribute 이름,\$입니다.json_name1,\$.json_name2($. 이후)가 JSON의 Name이 됩니다.
예를 들면 JSON.
{
"json_name1":"json_value1",
"json_name2":"json_value2"
}
만약 이런 물건이 온다면attribute1에 json이 있을 것이다value1은attribute2에 있습니다스토리지value2
저장된 attribute로 분기
아까와 같이 Processor를 Canvas에 끌어다 놓고 RouteOn Attribute를 선택하십시오.

Attribute를 추가합니다.Property에 attribute 이름,value에 조건문을 씁니다.조건문은 NiFi Expression 표기법에 따라 작성됩니다.예시에서 filename에 문자열 원이 포함되면case1을 되돌려줍니다.

그럼 카스1은 진짜로 PutFile에 연결하고 싶어요.RouteOn Attribute에서 PutFile로 드래그합니다.

RouteOn Attribute와 PutFile 사이에 connection을 생성하여 설정 화면을 표시합니다.
For relationships에서 case1을 선택합니다.
이렇게 카스1이 진짜일 때 이 연결을 통과할 수 있습니다.
마찬가지로,case2가 사실이라면 다른 프로세서에 연결하려면 Route On Attribute와 이 프로세서 사이를 드래그하여connection에서case2를 검사합니다.
테스트
공구는 여러 가지가 있는 것 같지만.이런 FireFox의dd-on은 매우 편리하다.
RestClient

좋은 웹페이지 즐겨찾기