You will likely need to use ExecuteSQL to query the database and you can reference attributes on the incoming flowfile using Expression Language. The resulting output will be placed in the content of the new flowfile, and you can use ExtractText, EvaluateJsonPath, etc. processors to move pieces of that content into the attributes of the flowfile.
Andy LoPresto [email protected] [email protected] PGP Fingerprint: 70EC B3E5 98A6 5A3F D3C4 BACE 3C6E F65B 2F7D EF69 > On Jul 18, 2017, at 9:45 AM, Praveen Reddy <[email protected]> wrote: > > Hi All, > > In my data flow, I need to query SQL database, based on input flow file > attribute, and update/add the attributes with the result of DB query. > > Can you please suggest the best approach for this in NiFi? > > Thank you. > > With Best Regards, > Praveen.B
signature.asc
Description: Message signed with OpenPGP using GPGMail
