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