About mtigua

mtigua · ‎05-09-2019

Hi everybody, please help! I'm working in NIFI with PutDataBaseRecord to insert the data of a csv file to a database table. Everything goes well in the first execution because there is no data in the table. Then I modify the file so it contains new records and existing ones. PutDataBaseRecord fails because of existing records (primary key constraint) but it doesn´t insert the new records. Is there any way to configure the processor to instruct it to insert the new records and ignore the ones that failed? I attached pictures how my processor is configured. Thanks in advance.

mtigua · ‎05-06-2019

Thanks @Wynner, it works!

mtigua · ‎05-02-2019

Hi everyone, please help! I'm using ListSFTP processor to get files and process them. In the first execution the processor take the files normally, but when you start the processor the second time it doesn't. I know this is the correct behavior for this processor. Is there any way to start and initialize the processor via NIFI API in such a way that It takes the files again? I need this approach because I need to do testing. Thanks!

mtigua · ‎03-22-2019

Hello everyone, please help! I have files whose name is formed by a date in the format "yymmdd", for example: TRB_ASE_D190125.txt TRB_TIT_D190125.txt I need to get only the files whose names match the current date. For example, if the date was "190125", the 2 subsequent files would match that criterion. I am using the ListFile processor to get the files and put this regular expression using the "now" function in the File Filter, but it does not work: ^TRB_[A-Z]+_D${now():format('yymmdd')}.TXT Thanks in advance!

Online	Offline
Last Visited	‎08-02-2019 03:50 PM

Member Since	‎03-21-2019 06:22 PM
Last Visited	‎08-02-2019 03:50 PM
Posts	9

Cloudera Community

PutDataBaseRecord does not insert any record when ...

Re: How to initialize a processor via NIFI API

How to initialize a processor via NIFI API

Get files using ListFile but filtering by its name...