Hello all I have a NiFi data flow that has flowfiles containing multiple json records (with exactly the same received time) and I'm trying to extract the timestamp as a flowfile attribute as follows: All the received times match as I'm using a PartitionRecord processor prior to EvaluateJsonPath, I have confirmed they are identical. I am aware that I can split > extract > merge but I am trying to avoid that due to the high volume of data passing through this flow, is there any way to just extract the first timestamp for all the records in a single flowfile using EvaluateJsonPath? or another record processor?   I am also trying to avoid having to use ExtractText and regex to pull the timestamp, again due to the volume of data in the flow.   There is an existing flow working in our production environment using plain/text and regex etc. I am trying to re-design using record processing to improve efficiency.    any assistance welcome.  🙂       ... View more

Hello, I have been tasked with POSTing a .rpm file (RedHat package manager) to a server location, this is to automate a manual process that we perform on a weekly basis.   I am able to download the file into NiFi using InvokeHTTP GET. At this stage the 'Content-Type' attribute shows as 'audio/x-pn-realaudio-plugin' , I have read online that this is a common mistake when dealing with .rpm files. I have then used a IdentifyMimeType processor which updates mime type to: application/x-rpm.   In the API documentation is says I require POST /rest/v1/updates as location 'file' as a parameter, see below: I have been given the following python script that achieves what I am trying to do in Python, so far I have not been able to replicate in Nifi. I have tried numerous different configs of the processor, manually changed attributes: file, filename, mime.extension, mime.type, Content-Type, Accept-Encoding. I have tried manually adding attributes from the Python script and referencing from the invoke. I have tried to compress to gzip as I was informed it should be in compressed format so I though NiFi had maybe changed it.   So far I have never had anything other than 'no retry' responses.   I currently have set up my invokeHTTP as below: When I have 'Send Message Body' true - I get the following response: When I set 'Send Message Body' false - I get:   Any assistance with this at all would be v.much appreciated. I have been trying for a number of days with every different option/config I can think of but cannot get it to POST.   In the script if mentions getting a 'csrftoken' response, am I able to do this using another invokeHTTP?   Thanks in advance   Griggsy           ... View more