About ranithsr

ranithsr · ‎01-10-2018

Thanks, I have the timestamp value in each flow file, I need to compare the timestamp of the current flow files with previous flow files and if it is greater write that to a file using the Put file processor. I tried this with the update attribute processor's advanced features in the following way: Added a rule named max_timestamp with the condition ${getStateValue("maxTimestamp"):lt(${timestamp})} and set the action for the attribute maxTimestamp as ${timestamp} I also turned set the store state feature to store locally in the processor, but I do not see the maxTimestamp attribute being set to the flowfiles output from the update attribute processor.

ranithsr · ‎01-09-2018

I have a processor group where I read page ID's from a file and retrieve all posts and comments for these pages, I run this every 2 hours. In the response body I get the timestamp of the created time of the post, I need to record the last largest timestamp of all the posts I received and pull only posts . One approach I though of was to record the timestamp attribute of each flowfile in a file and compare the value of this file with the next flowfiles timestamp, will this work, if not how could I achieve this.

ranithsr · ‎12-12-2017

I have an EvaluateJsonPath processor which adds the client id as an attribute to a flow file, client id is an integer without any double quotes, but when I later retrieve this and few other attributes using a AttributeToJson processor and get the results as a JSON output I get the client ID with double quotes in the following format: clientid : "2" I tried with JOLTTransformJSON processor too with following configuration: [ { "operation": "default", "spec": { "clientid":"${clientid}" } } ] and also with the replace function in an updateAttribute processor to replace double quotes but still I get it with double quotes, how can I get rid of the double quotes in resultant JSON.

ranithsr · ‎11-09-2017

Thanks a lot....it works perfect.

ranithsr · ‎11-09-2017

How can I make the following http post request using InvokeHttp processor: $ curl http://xxxxxxxx:8993/solr/demo/update -d ' [ {"url" : "xxxxxxxx", "sharecount" : {"set":10} } ] I have used a attributesToJson processor which outputs a flowfile in the following format: { url:"xxxxxxxxxxxx", sharecount:10 }

Online	Offline
Last Visited	‎01-31-2020 01:15 AM

Member Since	‎11-09-2017 09:38 AM
Last Visited	‎01-31-2020 01:15 AM
Posts	7

Cloudera Community

Re: Store and compare timestamp in Nifi

Store and compare timestamp in Nifi

Nifi Remove double quotes in attribute value

Re: JSON message body for invoke http processor

JSON message body for invoke http processor