LookupRecord 2025.5.31.15¶
번들¶
org.apache.nifi | nifi-standard-nar
설명¶
레코드에서 1개 이상의 필드를 추출하고 LookupService 에서 해당 필드에 대한 값을 조회합니다. LookupService 가 결과를 반환하면 해당 결과가 선택적으로 레코드에 추가됩니다. 이 경우 프로세서는 강화 프로세서로 기능합니다. 어쨌든, 기록은 ‘일치’ 관계 또는 ‘unmatched’ 관계(‘Routing Strategy’ 속성이 해당 방식으로 구성되어 있는 경우)로 라우팅되며, 이는 LookupService 에서 결과가 반환되었는지 여부를 표시합니다. 이를 통해 프로세서는 라우팅 프로세서로서의 기능도 수행할 수 있습니다. 조회 서비스에서 값을 조회할 때 사용할 ‘좌표’는 사용자 정의 속성을 추가하여 정의합니다. 추가되는 각 속성은 맵에 항목이 추가되며, 여기서 속성 이름이 맵 키가 되고 RecordPath 에서 반환된 값이 해당 키의 값이 됩니다. RecordPath 에서 여러 값을 반환하면 레코드는 ‘일치하지 않는’ 관계로 라우팅됩니다(또는 ‘Routing Strategy’ 속성의 구성에 따라 ‘성공’ 관계로 라우팅됩니다). 1개 이상의 필드가 결과 RecordPath 와 일치하면 일치하는 모든 필드가 업데이트됩니다. 구성된 LookupService 에 일치하는 항목이 없는 경우 필드가 업데이트되지 않습니다. 즉, 레코드의 기존 값을 null 값으로 덮어쓰지 않습니다. 그러나 LookupService 에서 반환된 결과가 스키마(특히 Record Writer에 대해 구성된 스키마)에 계정되지 않은 경우 필드가 FlowFile 에 기록되지 않는다는 점에 유의하십시오.
입력 요구 사항¶
REQUIRED
민감한 동적 속성 지원¶
false
속성¶
속성 |
설명 |
|---|---|
루트 레코드 경로 |
FlowFile 의 각 최상위 레코드 내의 하위 레코드를 가리키는 RecordPath 입니다. 지정하면 최상위 레코드 대신 이 하위 레코드에 대해 추가 RecordPath 속성이 평가됩니다. 이를 통해 1개의 최상위 레코드 내에서 여러 하위 레코드에 대해 보강 성능을 수행할 수 있습니다. |
lookup-service |
각 레코드에서 값을 조회하기 위해 사용하는 조회 서비스입니다 |
record-path-lookup-miss-result-cache-size |
캐시할 조회 값/레코드 수를 지정합니다. 이 속성을 0으로 설정하면 캐시가 수행되지 않고 각 레코드의 각 조회 값에 대해 테이블을 쿼리합니다. 조회 테이블이 자주 변경되거나 가장 최근 데이터를 검색해야 하는 경우에는 캐시를 사용하지 마십시오. |
record-reader |
수신 데이터를 읽는 데 사용할 컨트롤러 서비스를 지정합니다 |
record-update-strategy |
이 속성은 조회 서비스에서 반환된 값으로 레코드를 업데이트할 때 사용할 전략을 정의합니다. |
record-writer |
레코드 작성에 사용할 컨트롤러 서비스를 지정합니다 |
result-contents |
레코드가 포함된 결과를 얻으면 이 속성은 레코드 자체를 구성된 경로에 삽입할지 아니면 레코드의 내용(즉, 하위 필드)을 구성된 경로에 삽입할지 여부를 결정합니다. |
result-record-path |
조회 서비스에서 반환된 값으로 값을 업데이트해야 하는 필드를 가리키는 RecordPath 입니다. 지정하지 않으면 조회 서비스에서 반환되는 값은 FlowFile 을 ‘일치’ 또는 ‘일치하지 않는’ 관계로 라우팅할지 여부를 결정하는 것을 제외하고 무시됩니다. |
routing-strategy |
조회가 완료된 후 레코드를 라우팅하는 방법을 지정합니다 |
관계¶
이름 |
설명 |
|---|---|
실패 |
FlowFile 을 보강할 수 없는 경우 변경되지 않은 FlowFile 은 이 관계로 라우팅됩니다 |
성공 |
실패가 발생하지 않는 한, 모든 레코드는 이렇게 구성된 경우 이 관계로 전송됩니다. |
Writes 특성¶
이름 |
설명 |
|---|---|
mime.type |
Mime.type 특성을 Record Writer가 지정한 MIME 유형으로 설정합니다 |
record.count |
FlowFile 에 있는 레코드의 수 |