GeoEnrichIPRecord 프로세서
GeoEnrichIPRecord 프로세서
Openflow의 GeoEnrichIPRecord 프로세서는 레코드 기반 데이터셋을 대규모로 강화할 수 있도록 NiFi Record API를 사용하는 IP 지리 정보 프로세서예요. MaxMind 데이터베이스가 제공하는 각 필드를 사용자가 선택한 레코드 필드로 보내줘요.
출처: Snowflake 문서
본문
번들 (Bundle)
org.apache.nifi | nifi-enrich-nar
설명 (Description)
IP 주소의 지리 정보를 조회해 FlowFile 속성에 추가해요. 지리 데이터는 MaxMind 데이터베이스로 제공돼요. 이 버전은 NiFi Record API를 사용해 레코드 지향 데이터셋을 대규모로 강화할 수 있게 해줘요. MaxMind 데이터베이스가 제공하는 각 필드는 해당 필드 구성에 record path를 제공해 사용자가 선택한 필드로 보낼 수 있어요.
태그 (Tags)
enrich, geo, ip, maxmind, record
입력 요구 사항 (Input Requirement)
필수 (REQUIRED)
민감 동적 속성 지원 (Supports Sensitive Dynamic Properties)
아니요 (false)
속성 (Properties)
| 속성 | 설명 |
|---|---|
| City Record Path | IP 주소에 대해 식별된 도시를 넣을 record path예요. |
| Country ISO Code Record Path | 식별된 국가의 ISO 코드를 넣을 record path예요. |
| Country Postal Code Record Path | 식별된 국가의 우편번호를 넣을 record path예요. |
| Country Record Path | IP 주소에 대해 식별된 국가를 넣을 record path예요. |
| IP Address Record Path | 조회를 수행하기 위해 IP 주소를 가져올 record path예요. |
| Latitude Record Path | IP 주소에 대해 식별된 위도를 넣을 record path예요. |
| Log Level | 데이터베이스에서 IP를 찾지 못할 때 사용할 로그 레벨이에요. 허용 값: INFO, DEBUG, WARN, ERROR. |
| Longitude Record Path | IP 주소에 대해 식별된 경도를 넣을 record path예요. |
| MaxMind Database File | Maxmind IP 강화 데이터베이스 파일의 경로예요. |
| Record Reader | FlowFile 내용을 읽는 데 사용할 record reader 서비스예요. |
| Record Writer | FlowFile 내용을 강화하는 데 사용할 record writer 서비스예요. |
| Separate Enriched From Not Enriched | 강화된 레코드와 강화되지 않은 레코드를 분리할지 여부예요. 기본 동작은 레코드 하나라도 강화되면 모든 항목을 found 관계로 보내는 것이에요. |
관계 (Relationships)
| 이름 | 설명 |
|---|---|
| found | 데이터베이스가 제공하는 데이터로 속성을 성공적으로 강화한 뒤 FlowFile을 보낼 곳이에요. |
| not found | 데이터를 찾지 못해 속성 강화에 실패한 FlowFile을 보낼 곳이에요. |
| original | 콘텐츠가 강화되었는지와 무관하게 원본 입력 flowfile이 이 관계로 보내져요. |