I created a template to convert data from querying Postgres database and then convert it into xml. I want to run it by using command line arguments. Are there any way to do this in NiFi?   Thank you ... View more

Hi guys! I have a question about Avro schema. My input flowfile are in json format and I want to convert it into xml. The method I use is using ConvertRecord Processor. In terms of ConvertRecord Processor, I use JsonTreeReader as record reader and XMLRecordSetWriter as record writer. Following picture is the properties of JsonTreeReader I set it up.  Here is the json I want to convert:   { "article":{ "article-meta": { "art_id": "me08001", "title" : [ { "lang" : "en", "title" : "A" }, { "lang" : "hr", "title" : "B" } ] }, "journal-meta": { "journal_id": "me9", "type" : "journal" } }   If I have a lot of flowfile that contain this kind of format Json file, what Avro schema should I put inside AvroSchemaRegistry. I try a lot of online converter and it doesn't satisfy AvroSchemaRegistry when I do validation. I need the Avro schema so that the ConvertRecord can read my JSON flowfile. Thank you in advance       ... View more

Hi, Guys. I am new to use NiFi flow. I am kind of confused about Query database table processor. So now, I am try to get all data from Postgres database and convert them into json and then convert them into xml. But sometimes, the Query database table processor will have a lot of Flow file and then the queue just mess up. I try to set the art_id to be maximum-value column but it doesn't work well because art_id is string.(not sure) This is a screenshot from a sample table called title and it has about 500 rows. How to query them just one time and split them into 500 flowfile and each of flowfile has only one row from table title without any duplicates. Can someone help me? Thank you so much. Following screenshots are my progress so far.           ... View more