Hello I have the following : Tomcat server (local) Nifi (local) customer csv file In my flow I am getting the file content and transforming it to a json body (the body I need to send it in the API post). The problem is to use the invokeHTTP processor to send the api (onboard) I need to get a token via another API (auth) and add it in the header of the main api (onboard).   Auth API :  Sends a json to the tomcat :     { "user_name": "User", "password": "Password" }     And get a json with a token valid for 2 min     { "id": 1, "user_name": "user", "token": "eyJhbGciOiJIUzUxMiJ9.eyJzdWIiOiJzdXBlcmFkbWluIiwidGV...", "roles": [ "USER", "ADMIN" ], "homePage": null, "priorite": 0 }       The problem is when I pass the customers json to the auth API it will take that json as the body for that API and I lose my customer json. Is there another way to get the token from the auth API and use it in the onboard API header without losing the customers json (main flow)?   ... View more

Hello I have created a JSON body but I need to reconstruct it so I can send it in a REST API. Input :   { "systemId" : "4", "systemName" : "Main", "items.nid" : "123", "items.birth_date" : "1978-01-01", "items.last_name" : "Willson", "items.nationality" : "GN", "formId": 1 }     Output :   { "formId": 1, "systemId" : "4", "systemName" : "Main", "items" { "nid" : "123", "birth_date" : "1978-01-01", "last_name" : "Willson", "nationality" : "GN" } }     I used JoltTransformJSON but with no luck always get null as a result, I can't figure how to regroup them based on the name "items.*" . how can I regroup my items or is there a better way to solve this point ? ... View more

I need to create a flow that update rows in my database based on csv file. I have : 1- GetFile status client_id Active 123 Inactive 456   2- UpdateAttribute to update the Baobab_file (the schema is already in the AvroSchemaRegistry (collection)   3- SplitRecord to get each line  status client_id Active 123   4- ExecuteSQL : update table_client set current_status = status where id = client_id   How can I do this I tried ${status} and \status but no luck   Thank you ... View more

Hello I'm using Postgresql with NIFI, how can I specify the schema I want to use from Postgresql     There is no option for the schema in the DBCPConnectionPoll.     and there is no option for schema also in the lookup service      ... View more

Hi, I am getting a csv without a header then adding a header with ReplaceText to it after the ReplaceText the header is added but the rest is crashed. PS: This problem happen with this file only I tried the flow with other csv files and worked fine, can this be a csvReader problem or configuration on the encoding ?   Before : The replace :    After : ... View more

Hello, I'm trying to learn NIFI so this is all new to me, I used to work with Talend and I have hard time translating to NIFI. So the main idea: For example is I have two tables in Postgresql   Table CITY : ID (auto generated), city_name Table PERSON : ID (auto generated), first_name, last_name, city_id   and I have a CSV file : first_name, last_name, city_name   Can you please explain how I can insert in tow tables from one flowfile and refer in the table PERSON to the ID of the city not the name from the table CITY. Thank you. ... View more