GetMongo question

I am using the getMongo processor but every time it runs, it is returning results from the beginning of time. I have my processor schedule to run every ten minutes. I would like it to return only the new results since the last time the processor ran. Is there a way to do that?

Re: Help with replace method

Thanks Joe. It worked great. On Wed, Apr 27, 2016 at 12:19 AM, Joe Percivall wrote: > Hello Igor, > > I got your template working by using the below replacement string and > changing the "Replacement Strategy" to "Always Replace". I've attached a > template that works for me. > > {"test":"${test

Re: Nifi parsing examples

Sorry that was just for example #2 :) > On Apr 27, 2016, at 3:59 PM, Matt Burgess wrote: > > If you can represent the expected string format as a regular > expression, you can use the replaceAll() function [1] with > back-references: > > ${url:replaceAll('(http://[a-zA-Z0-9]+:)[a-zA-Z0-9]+(@.*

Re: Nifi parsing examples

If you can represent the expected string format as a regular expression, you can use the replaceAll() function [1] with back-references: ${url:replaceAll('(http://[a-zA-Z0-9]+:)[a-zA-Z0-9]+(@.*)','$1x$2')} original: http://username:p...@host.com after: http://username:xx...@host.com Note I h

Nifi parsing examples

Friends, I am looking for attributes parsing examples. Any help is appreciated? I want to get difference between two feilds attributes 1. let say end - start: ${end:minus(${start}) is this right way to do it? 2. I want to mask password in the url, how can i do it? example: http://username:p.

Re: Help with replace method

Sorry for late response. Thanks Joe. I will take a look. So if I want to replace also new line '\n' with character representation "\n" I will need to do this {"test":"${teststr:replaceAll('"','"'):replaceAll('\n', 'n'}"}. Correct? On Wed, Apr 27, 2016 at 12:19 AM, Joe Percivall wrote:

Re: Apache NiFi with Fail2Ban

Stephane, You should be able to uninstall the nifi service manually by removing the following files: /etc/rc2.d/S65nifi /etc/init.d/nifi /etc/rc2.d/K65nifi Thanks -Mark > On Apr 27, 2016, at 5:26 AM, Stéphane Maarek > wrote: > > Hi, > > I think I have messed something up and I need some h

Re: Connecting a Reporting Task to a Processor

Hi Brett, Reporting Tasks are not designed to send data specifically to Processors, but rather to send data to 'some arbitrary place'. In the case of MonitorDiskUsage, it is simply logging the information. So I don't think that connecting the reporting task to a processor is the right route to

Connecting a Reporting Task to a Processor

Hi everyone, I'm pretty new to using NiFi and am running into a road block I was hoping someone could share some insight on. I inherited a custom processor that deletes data from a folder when disk space usage is set to a given threshold. The oldest data gets deleted first until the threshold i

Apache NiFi with Fail2Ban

Hi, I think I have messed something up and I need some help I downloaded and untar nifi on my raspberry pi. Then I installed the service which is working (I can access nifi through my browser) Now something I can't do is the following: sudo apt-get install fail2ban How can I cleanly remove the ni