NiFi Processors for handling data in Redis
This processor is currently incomplete, but will be a simple Redis source, much like GetKafka. New FlowFiles will be created from the contents of a Redis key(s).
This processor is under active development. The processor accepts FlowFiles and then looks at the contents of a Redis hash based on the processor's configured "topic" and the UUID of the flowfile. If the specified number of values are in the redis hash for the given flowfile, the contents from Redis will either be added as attributes to the FlowFile or used to enrich the content. Currently, only enrichment of JSON is supported.
- Redis Connection String: The Connection String to use in order to connect to Redis.
- Client Name: Client Name to use when communicating with Redis
- Topic: Prefix of keys to gather data from, i.e. $topic:$flowfileUUID
- Enrichments: Number of required enrichments in the key's hash
- JSON Content Mode: If TRUE, add the enrichment data to the JSON, otherwise add as FlowFile attributes
- JSON Enrichment Field: If in JSON Content Mode, add the enrichments to this top-level JSON field