Member since
06-19-2017
62
Posts
1
Kudos Received
7
Solutions
My Accepted Solutions
Title | Views | Posted |
---|---|---|
2522 | 03-17-2022 10:37 AM | |
1759 | 12-10-2021 04:25 AM | |
2324 | 08-18-2021 02:20 PM | |
6278 | 07-16-2021 08:41 AM | |
1154 | 07-13-2021 07:03 AM |
12-13-2020
10:59 PM
Hi , I have to log Nifi processor success or errors status in shell script to monitor the flow . Please help with solution . I have tried using Updateattribute and log the message in a filesystem and could not complete it . Also i can not access nfi-app.log file into Edge node. Would like to do through REST API calls or some other solution . Thanks
... View more
Labels:
- Labels:
-
Apache NiFi
11-18-2020
10:50 PM
I have Parameter-context which has 6 parameters and i could understand that using nifi CLI or REST API we can update the values dynamically . We are not using Variable registry now.
... View more
11-17-2020
03:47 AM
I have Nifi flow created (ListSFTP-->FetchSFTP-->PutHDFS) and have parameters like sourcedir,hostname,HDFS path ,etc..I would like to pass the values dynamically instead of maintaining the parameter values in parameter context so that if there is any value changes , i can do in properties file itself. I have tried to use lookup attribute processor but we do not have CouchDB in the cluster . Please suggest option to pass dynamic values to this parameters. Like in Java program , we pass properties files to maintain default values. @Nifi @NifiDev
... View more
Labels:
- Labels:
-
Apache NiFi
06-21-2017
02:55 PM
jsonmerge.png jsonflowfilecontent.png Thanks a lot for the information ..i have google the above and able to get value for one attribute ..for example if i want to append/add values for n number of attributes which are all having null values and that needs to be updated dynamically ..how we can implement this as i am getting some of values from different processors like Http to put/append the values to empty attributes of json data.. I have tried merging two json flow file to one flowfile but the merge did not come with proper json format as it does not have comma separated in each json object of final flow file .Please refer jsonflowfilecontent.png and jsonmerge.png screenshots for more information. How we can achive this one..Any idea which you people come across this scenrios earlier.. I.e i have 50 fields json format data where i have 30 fields having values and remaining 20 does not have values or empty or null.but i have values for those 20 columns from other processor like Jms queue and i will have to append the jms queue values to match the correct fields and update the values ..this process needs to be automated in nifi for my project ..i will get values for 20 fields and append to orginal json format data then send to kafka queue. For this also do i need to follow the same procedure as below ??
... View more
06-20-2017
05:52 AM
Thank you . I am looking integrate/update multiple json fields with values from another processor .What is the best way to have dynamic fields. Thanks Adhi
... View more
06-20-2017
05:00 AM
Hi, Can i know how you will write Nifi expression language for 5 fields of json that values coming from another processor.Suppose i have 40 fields in json and 25 having values but 15 fields does not have values/empty fields to it. But i will get the values for 15 fields from another processor and i want to append the values to the 15 empty fields of current json content. Please can you tell me the procedure to do it. sample json file {
"index": 1, "index_start_at": 56, "integer": 31, "float": 11.8891, "name": "Kyle", "surname": "Ritchie",
"fullname": "Maria Kelley",
"email": "",
"bool": ""
}, where email and bool fields are emptry/null , i want to add values from another processor. How we achive it ..any steps and screenshots would be great .
... View more
06-20-2017
04:59 AM
Hi, Is there any steps to take our own kafka server metrics to elasticsearch..because we have grafana which will have all the dashboards but some of our project requirement need to keep few kafka metrics in kibana visualization.so we want to index the kafka metrics logs to elasticsearch. Can we consume kafka metrics into elasticsearch ?
... View more
06-19-2017
05:56 PM
Hi @Sonu Sahi It would be great if you share some screenshots on how to update/append the values for empty attributes of JSON data from other processor to existing processor dynamically as i need it for my project activities immediately . I am trying myself to do that as much as possible. Thanks Adhi
... View more
06-19-2017
04:37 PM
@Sonu Sahi Thank you very much. I have started my project recently and could you please help some sample examples with screenshots on how you are doing it. As i am new to this nifi and have to complete some activity to add values dynamically to empty json attributes .i.e suppose i have 40 fields , in that 25 fields having values and remaining 15 fields does not have values /empty. So with the help of another processor i want to append/update values to 15 empty attributes with values. Please can i have some screenshots which you have done this please Thanks Adhi
... View more
06-19-2017
04:27 PM
how to append values for empty flowfile attributes for JSON format data. i.e suppose i have 40 columns with JSON data consuming from kafka queue and i have values for 25 fields only and remaining 15 fields, i don't have values .So i put the json into EvaluateJsonPath processor and converted into flowfile attributes ..From some other processor i am getting values for those empty attributes so i need to append/fill the empty attributes with the values with orginal json file. Can you please suggest how to use it? thanks
... View more
- « Previous
- Next »