Implementing Invokehttp Processor In Nifi

Question

Please help me out in this scenario:1. I have to create a new project. The details are accessed using GetFileProcessor.2. I have passed two input to Invokehttp Processor(one Authorization token using CustomField and other as data to be used for POST action). However, this process is not working as expected. Please find the attached screenshot for reference. Data To be used for POST:  Early Response much appreciated!Thanks!

MattWho · Accepted Answer

@midee
The invokeHTTP processor will not execute against multiple FlowFiles collectively. You need to have one FlowFile that contains both your token in a FlowFile attribute and the desired content you are trying to post in the content.

The dataflow that obtains the token could be merged with the other dataflow that has yoru content.
If you have multiple FlowFiles that will need to use the same token, yo could have to separate dataflows.
One that gets the token and rights it to a distributed Map Cache via the PutDistributeMapCache processor.
Second dataflwo the gets your content file and fetches the token via the FetchDistributedMapCache processor.

Then you have one FlowFile with the token you need in an attribute and the content on the FlowFile to be transferred via InvokeHTTP.

If you found this assisted with yoru query, please take a moment to login and click "Accept" on this solution.

Thank you,
Matt

midee · Answer

Please help me ..This is bit urgent. Thanks!

Sign up

Please use your Cloudera account.

Login to the community

Please use your Cloudera account.