PutDistributedMapCache 프로세서
PutDistributedMapCache 프로세서
PutDistributedMapCache는 FlowFile의 내용을 읽어 분산 맵 캐시(distributed map cache)에 저장하는 OpenFlow 프로세서예요.
출처: Snowflake 문서
본문
이 프로세서는 일반 사용 가능(Generally Available) 상태예요. OpenFlow Snowflake 배포는 AWS, Azure, GCP 상용(Commercial) 리전의 모든 계정에서 사용할 수 있고, OpenFlow BYOC 배포는 AWS 상용 리전의 모든 계정에서 사용할 수 있어요.
Bundle org.apache.nifi | nifi-standard-nar
설명
FlowFile의 내용을 가져와서 FlowFile 속성(attribute)으로부터 계산한 캐시 키를 이용해 분산 맵 캐시에 저장해요. 캐시에 이미 항목이 있고 캐시 업데이트 전략이 'keep original'이면 항목을 교체하지 않아요.
Tags cache, distributed, map, put
입력 요구 사항 필수(REQUIRED)
민감 동적 속성 지원 아니요(false)
속성 (Properties)
| 속성 | 설명 |
|---|---|
| Cache Entry Identifier | FlowFile 속성이나 Attribute Expression Language 문장의 결과로, FlowFile에 대해 평가해 캐시 키를 결정해요. |
| Cache update strategy | 캐시에 이미 항목이 있을 때 캐시를 어떻게 업데이트할지 결정해요. |
| Distributed Cache Service | FlowFile을 캐시하는 데 사용하는 Controller Service예요. |
| Max cache entry size | 캐시에 넣을 수 있는 최대 데이터 양이에요. |
관계 (Relationships)
| 이름 | 설명 |
|---|---|
| failure | 캐시에 삽입하지 못한 FlowFile이 라우팅되는 관계예요. |
| success | 캐시에 성공적으로 삽입된 FlowFile이 라우팅되는 관계예요. |
기록되는 속성 (Writes attributes)
| 속성 | 설명 |
|---|---|
| cached | 모든 FlowFile은 'cached' 속성을 가져요. 이 속성의 값은 FlowFile이 캐시되면 true, 그렇지 않으면 false예요. |