À 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