/${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
>>>
>>>
>>
>>
>
