NiFI SQL Lookup Service is a SQL-based lookup service. It allows you to enrich your flowfiles with any jdbc-compliant data store.
It includes LookupRecord and LookupAttribute controllers.
These controllers were designed to be flexible and fast. They support:
- Named Parameters:
SELECT name FROM foo WHERE value = :value
- SQL IN queries:
SELECT name FROM foo WHERE value IN(:values)
- Multiple lookup values:
SELECT name FROM foo WHERE value IN(:values) AND sequence = :sequence AND catalog = :catalog
- Caching: LookupRecord and LookupAttribute both keep a cache of the most accessed objects. This is configurable in the controller settings.
-
Compile and install
nifi-sqllookup-bundle
> cd nifi-sqllookup-bundle
> mvn package
> cp ./nifi-sqllookup-services-nar/target/nifi-sqllookup-services-nar-1.10.0.nar /NIFI_INSTALL/lib/
> cp ./nifi-sqllookup-services-api-nar/target/nifi-sqllookup-services-api-nar-1.10.0.nar /NIFI_INSTALL/lib/
- Start NiFi
https://mrcsparker.github.io/nifi-sqllookup-services-bundle
https://github.com/mrcsparker/nifi-sqllookup-services-bundle/releases/latest