Member since
04-05-2018
44
Posts
2
Kudos Received
0
Solutions
08-27-2019
02:06 AM
Hey can you please help me with extracting regex attribute from a json file. I am trying to take attribute from a json file, this attributes have regex values. For ex: json file is - { "key1" : "(.{2})(.{4})", "key2" : "$1,$2"} From this json file I would need to take key1 and key2 in replacetext processor to search(key1) and replace by (key2). Please suggest a way to do this. Thanks!!
... View more
10-17-2018
01:50 PM
@Suresh Denukuri You can use the query property in GetMongo Processor. If you have the query in the body of an incoming flowfile, leave it blank, else you can specify the query here.
... View more
10-11-2018
12:25 PM
Hi Thanks for your response and time
... View more
10-10-2018
12:29 PM
Thanks for timely help and support
... View more
10-10-2018
12:30 PM
Thanks for your time and help
... View more
10-05-2018
07:48 PM
Thanks for your Answer
... View more
10-02-2018
10:02 PM
Thanks for your response , How to use Curl Command in Execute stream command processor ? please let me know you ahve any thoughts for same
... View more
06-30-2018
04:52 AM
Record-based processors should be writing the "record.count" attribute to outgoing flow files, but PutElasticsearchHttpRecord does not currently. I have written NIFI-5356 to cover this improvement. In the meantime, if you are using other record-based processors upstream, you may find you already have a record.count attribute, and since PutElasticsearchHttpRecord transfers the entire flow file to either success or failure, then if the attribute is there and the flow file is transferred to success, then "record.count" correctly indicates the number of records loaded into ES by that processor (for that flow file).
... View more
07-25-2018
03:12 PM
Hi Matt, I am trying to use the RunMongoAggregation processor and ran into 2 issues. 1. I ran an aggregation in my mongo very similar to this:
[ { $project: { lastUpdated: { $dateFromString: { dateString: '$lastUpdated' } } } } ] It changes the "lastUpdated" value from a string type to a DateTime type. The result looks like this:
lastUpdated 2018-07-23T10:15:05Z DateTime
I tried this in the RunMongoAggregation and with double quotes around each field as this link suggests https://nifi.apache.org/docs/nifi-docs/components/org.apache.nifi/nifi-mongodb-nar/1.6.0/org.apache.nifi.processors.mongodb.RunMongoAggregation/additionalDetails.html But the result I got looks like this:
lastUpdated NumberLong("1532340905000") Int64 2. When data gets aggregated in this processor, the mongo id is lost and becomes some sort of timestamp _id timestamp machingIdentifier processIdentifier counter time date timeSecond I wanted to keep the mongo id but it gets transformed to this. Any suggestions would help. Thank you
... View more
06-18-2018
10:42 PM
Thanks .. I will check the same
... View more