PutRedisHashRecord 프로세서
PutRedisHashRecord 프로세서
PutRedisHashRecord는 각 레코드의 필드에서 hash 값을 결정하는 RecordPath로 지정된 hash 값을 사용해 레코드 필드 데이터를 Redis에 저장하는 OpenFlow 프로세서예요.
출처: Snowflake 문서
본문
이 프로세서는 일반 사용 가능(Generally Available) 상태예요. OpenFlow Snowflake 배포는 AWS, Azure, GCP 상용(Commercial) 리전의 모든 계정에서 사용할 수 있고, OpenFlow BYOC 배포는 AWS 상용 리전의 모든 계정에서 사용할 수 있어요.
Bundle org.apache.nifi | nifi-redis-nar
설명
각 레코드의 필드에서 hash 값을 담고 있는 RecordPath로 결정되는 지정된 hash 값을 사용해 레코드 필드 데이터를 Redis에 넣어요. 레코드 필드와 값은 hash 값으로 연결된 key/value 쌍으로 저장돼요. 참고: 평가된 hash 값이나 필드 값 중 어느 것도 null이 될 수 없어요. hash 값이 null이면 FlowFile은 failure로 라우팅돼요. 각 필드 값이 null이면 Redis에서 해당 필드는 설정되지 않아요.
Tags hash, put, record, redis
입력 요구 사항 필수(REQUIRED)
민감 동적 속성 지원 아니요(false)
속성 (Properties)
| 속성 | 설명 |
|---|---|
| charset | 레코드 필드 값을 문자열로 저장할 때 사용할 문자 집합을 지정해요. 모든 필드는 Redis에 저장되기 전에 이 문자 집합으로 변환돼요. |
| data-record-path | 각 들어오는 레코드에 대해 평가될 RecordPath를 나타내는 속성이에요. RecordPath를 평가한 결과로 나온 레코드가 들어오는 전체 레코드 대신 Redis로 보내져요. 'flat' 레코드(모든 필드/값이 레코드 최상위 수준)에 해당하는 루트 '/'가 기본값이에요. |
| hash-value-record-path | 모든 레코드 필드/값과 연결될 hash 값을 결정하기 위해 각 레코드에 대해 평가할 RecordPath를 지정해요(자세한 내용은 Redis 문서의 'hset' 참조). RecordPath는 정확히 하나의 필드를 가리켜야 하며 그렇지 않으면 오류가 발생해요. |
| record-reader | 들어오는 데이터를 파싱하고 데이터의 스키마를 결정하는 데 사용할 Controller Service를 지정해요. |
| redis-connection-pool | Redis 연결 풀이에요. |
관계 (Relationships)
| 이름 | 설명 |
|---|---|
| failure | 처리 오류가 있는 레코드를 포함한 FlowFile이 이 관계로 라우팅돼요. |
| success | 모든 레코드가 Redis에 저장된 FlowFile이 이 관계로 라우팅돼요. |
기록되는 속성 (Writes attributes)
| 속성 | 설명 |
|---|---|
| redis.success.record.count | Redis에 기록된 레코드 수예요. |