À users
Hello   !

I am new to Nifi and  I'm trying to find the best workflow to update or
append content  to the MapCache

I created my  DistributedMapCacheServer and Service.

I have several simple flowlogs with Content Like this:

 {
  "eventType" : "api",
  "message" : "blabla"
}
and simple Attribute "ServiceName" : abcd"

1 )
At firts i created aggregation using MergeRecord   with my correlation
attribute set on  ${ServiceName)
the output is something like this :
 [ {
  "eventType" : "api",
  "message" : "blabla"
}, {
  "eventType" : "api",
  "message" : "blabla"
}, {
  "eventType" : "api",
  "message" : "blabla"
 }]

I then add the value to the cache with  PutDistributedMapCache and  cache
entry identifier on  ${ServiceName}

but i'am blocked with the featching ,  I wish  add the new aggregation
value with the values provided by the cache but  if link the mergedRecord
with FetchDistributedMapCache  operator will replace my value by the cache
value and  i will lost the context of my entry

i'am taking a look on "Put Cache Value In Attribute"    in order to keep
both context but I'm not sure if  I can then merge the attributes in the
Content ....

Thank for  your suggestion !

Yanna elina

Reply via email to