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 >> >> > >
