Is there any way to invoke remote rest service via invokeHttp nifi processor and change its url permamently. In my case I need to pass 2 paramters to get request and I need to change them time after time. Is there any nifi processor which I can use for writing my parameters as attributes in it and connect it with invokehttp consequently? My parameters in invokehttp remote url will change, is there any processor or maybe several processors which can help me make this task?
How to invoke remote rest service in InvokeHttp nifi processor?
3.6k Views Asked by Sagitarius At
1
There are 1 best solutions below
Related Questions in REST
- Query parameter works fine with fastapi application when tested locally but not working when the FastAPI application is deployed on AWS lambda
- Add an http GET/POST entry point to a Django with channels websocket
- Difficulty creating a data pipeline with Fabric Datafactory using REST
- Flutter connection to a local api
- Accessing REST API Status Codes using Azure Data Factory Copy Activity (or similar)?
- Mass Resource deletion in REST
- why when I check endpoint /tasks, an error always appears "error : invalid token" even though I have entered the appropriate token that I got
- How to prevent users from creating custom client apps?
- How to create a REST API with .NET Framework?
- Efficiently Handling Large Number of API Calls with Delphi 10.4 and OmniThreadLibrary
- Put Request throwing 401 [no body] Unauthorized
- Converting img src data to octet-stream
- Implementing Email Verification and Notification System in a Full-Stack Application with React Frontend and Node Backend
- Micronaut - Add Controller from external library
- Moving Template or OVA to Datastore using vCenter API
Related Questions in APACHE-NIFI
- How to split a flow file json in nifi
- Nifi queryrecord compare regex using rpath on first level of record
- How to compare two csv files line by line in apachi nifi flow file using groovy script
- Apache nifi Invoke Http with url containing %2F
- localhost 8443 refused to connect
- Apache NIFI: Unable to write flow content
- Copy/Merge multiple HDFS files using Nifi Processor
- How to count the number of records of a JSON object using JOLT
- Jolt to remove the slashes and extract the nested json
- Customize Apache Nifi Frontend
- Apache NIFI getMongo An unexpected error has occurred: The specified data reference URI is not valid
- Filter JSON Array to Keep Only the Entry with the Latest Date/Time Using Jolt
- How to get hold of input file from a flowfile?
- How to let Airflow know that a Ni-Fi pipeline involving multiple flows is complete
- Creating connection from RouteOnAttribute to GetFile
Related Questions in WEBSERVICES-CLIENT
- CXF directory must be set in global preferences SOAP UI
- jax-ws redirect http / https
- Java soap client for EJBCA webservices
- How to add security header parameters to SOAP Request in java
- How do I use the web service classes generated with Eclipse from WSDL file?
- 503service unavailable in Salesforce
- How to return JSON in REST get method using the Odoo full API
- Javax.xml.ws Client for OAuth2.0
- Calling a web soap webservice with basic authorization
- Create a web service client in Hybris
- How to capture soap error response for an Invalid data in request?
- Ignore invalid Enum values in SOAP deserialization
- Error initializing the HttpClient variable
- Unit Test Mock for Spring Boot Rest Api
- VBA webservcie call takes time and excel goes to Not responding
Trending Questions
- UIImageView Frame Doesn't Reflect Constraints
- Is it possible to use adb commands to click on a view by finding its ID?
- How to create a new web character symbol recognizable by html/javascript?
- Why isn't my CSS3 animation smooth in Google Chrome (but very smooth on other browsers)?
- Heap Gives Page Fault
- Connect ffmpeg to Visual Studio 2008
- Both Object- and ValueAnimator jumps when Duration is set above API LvL 24
- How to avoid default initialization of objects in std::vector?
- second argument of the command line arguments in a format other than char** argv or char* argv[]
- How to improve efficiency of algorithm which generates next lexicographic permutation?
- Navigating to the another actvity app getting crash in android
- How to read the particular message format in android and store in sqlite database?
- Resetting inventory status after order is cancelled
- Efficiently compute powers of X in SSE/AVX
- Insert into an external database using ajax and php : POST 500 (Internal Server Error)
Popular # Hahtags
Popular Questions
- How do I undo the most recent local commits in Git?
- How can I remove a specific item from an array in JavaScript?
- How do I delete a Git branch locally and remotely?
- Find all files containing a specific text (string) on Linux?
- How do I revert a Git repository to a previous commit?
- How do I create an HTML button that acts like a link?
- How do I check out a remote Git branch?
- How do I force "git pull" to overwrite local files?
- How do I list all files of a directory?
- How to check whether a string contains a substring in JavaScript?
- How do I redirect to another webpage?
- How can I iterate over rows in a Pandas DataFrame?
- How do I convert a String to an int in Java?
- Does Python have a string 'contains' substring method?
- How do I check if a string contains a specific word?
Bryan answered this with a comment in response to your previous question.
To provide dynamic values that are used as parameters in the request URI, simply reference attributes on the incoming flowfile using the Apache NiFi Expression Language. Many processors can provide those attributes, but
UpdateAttributeis probably where you want to start. For example, if that processor sets two attributes (usernameandthreshold), you would have a series of flowfiles like this:Flowfile 1 | username 'andy' | threshold '27'Flowfile 2 | username 'bryan' | threshold '12'Flowfile 3 | username 'sally' | threshold '22'Your
InvokeHTTPprocessor would be configured with a URI likehttps://my.remote.service:8080/incoming?username=${username}&threshold=${threshold}. Thus, as the flowfiles pass through the processor, your outgoing HTTP requests would be:https://my.remote.service:8080/incoming?username=andy&threshold=27https://my.remote.service:8080/incoming?username=bryan&threshold=12https://my.remote.service:8080/incoming?username=sally&threshold=22