Expression Language can be used to dynamically set the path to look for,
using the flow file attributes. As Mike said, if you have
authority=MyAuthority in your flow file attributes, then LookupRecord
configured with /${authority} will behave exactly as if you configured the
processor with /MyAuthority, nothing else.If you're trying to do something else, can you provide an example? I'm not sure I get what you'd expect. Pierre 2018-05-25 14:30 GMT+02:00 Thomas P. <[email protected]>: > in the json example from my first post the field "authority" is set and in > this case I could use /authority > but when this field is not available in the content? > > { > "code": "A1234", > "descriptions": [ > { > "language": "EN", > "description": "Nifi rocks!" > } > ] > } > > > > > On 25 May 2018 at 14:13, Mike Thomsen <[email protected]> wrote: > >> /${authority} will yield a record path of /MyAuthority, but there is no >> "MyAuthority" in your flowfile. >> >> /authority, however, will do a lookup on the record and should find the >> value MyAuthority and set a map of { authority => MyAuthority } for the >> lookup service. >> >> On Fri, May 25, 2018 at 8:02 AM Thomas P. <[email protected]> >> wrote: >> >>> authority is an existing attribute on the flowfile. In the content >>> itself this field is not available thats why I want to use the attributes >>> value for querying. >>> >>> >>> >>> On 25 May 2018 at 13:40, Pierre Villard <[email protected]> >>> wrote: >>> >>>> Hi, >>>> >>>> Is 'authority' an existing attribute in the incoming flow files or is >>>> it only an information available in the content of the flow file ? >>>> >>>> Pierre >>>> >>>> 2018-05-25 13:07 GMT+02:00 Thomas P. <[email protected]>: >>>> >>>>> Hello community, >>>>> >>>>> I am trying to query a MongoDB using LookupRecord which works fine >>>>> when I read the values directly from the json flow file. >>>>> But when I try to query the MongoService using an attribute, I don't >>>>> find the expected document. >>>>> >>>>> Here is my nifi 1.6 setup: >>>>> >>>>> json flow file: >>>>> { >>>>> "code": "A1234", >>>>> "authority": "MyAuthority", >>>>> "descriptions": [ >>>>> { >>>>> "language": "EN", >>>>> "description": "Nifi rocks!" >>>>> } >>>>> ] >>>>> } >>>>> >>>>> avro schema: >>>>> { >>>>> "type" : "record", >>>>> "name" : "MyClass", >>>>> "namespace" : "com.test.avro", >>>>> "fields" : [ { >>>>> "name" : "code", >>>>> "type" : "string" >>>>> }, { >>>>> "name" : "authority", >>>>> "type" : "string" >>>>> }, { >>>>> "name" : "descriptions", >>>>> "type" : { >>>>> "type" : "array", >>>>> "items" : { >>>>> "type" : "record", >>>>> "name" : "descriptions", >>>>> "fields" : [ { >>>>> "name" : "language", >>>>> "type" : "string" >>>>> }, { >>>>> "name" : "description", >>>>> "type" : "string" >>>>> } ] >>>>> } >>>>> } >>>>> } ] >>>>> } >>>>> >>>>> two documents in mongo: >>>>> { >>>>> "_id" : ObjectId("5b07db234fad446628118dde"), >>>>> "code" : "A1234", >>>>> "authority" : "MyAuthority", >>>>> "descriptions" : [ >>>>> { >>>>> "language" : "EN", >>>>> "description" : "Nifi rocks!" >>>>> } >>>>> ] >>>>> } >>>>> >>>>> { >>>>> "_id" : ObjectId("5b07db374fad446628118e10"), >>>>> "code" : "A1234", >>>>> "authority" : "AnotherAuthority", >>>>> "descriptions" : [ >>>>> { >>>>> "language" : "EN", >>>>> "description" : "Nifi still rocks!" >>>>> } >>>>> ] >>>>> } >>>>> >>>>> >>>>> >>>>> >>>>> >>>>> >>>>> Now I try to query MongoDB using a value from an attribute but it >>>>> never matches. >>>>> The attribute 'authority' is set via UpdateAttribute and contains >>>>> value "MyAuthority". >>>>> >>>>> >>>>> >>>>> >>>>> How can I query my document using attribute? >>>>> >>>>> >>>>> Thomas >>>>> >>>>> >>>> >>>> >>> >
