Member since
04-05-2018
44
Posts
2
Kudos Received
0
Solutions
10-05-2018
07:48 PM
Thanks for your Answer
... View more
10-04-2018
07:40 PM
Hi I am trying to execute python script using executestreamcommand processor . it was giving error "No Such file or Directory " even file is available in respective directory my Flow => Generate file processr --> Execute stream command processor I was two methods for passing arguments to Execute stream command processor for Method 1: ${arg1},${argg} are passed by generate file processor commandarguments :/home/suresh/Desktop/wquest1.py ${arg1};${arg2} command path : python3.6 Method 2: commandarguments : wquest1.py ${arg1};${arg2} command path : python3.6 Working directory : /home/suresh/Desktop/ Please help me on this issue . Thanks for your time and consideration
... View more
Labels:
- Labels:
-
Apache NiFi
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
10-02-2018
03:39 PM
Thanks for your suggestion . Please direct me any links/information for same
... View more
10-01-2018
05:03 PM
Hi I am trying create serial workflow which will execute the Processors in sequence fashion , I was tried different processors but not able to build this pipe line . Please help me ont his regard Processor flow update attribute -->putlelasticsearchhttp (successful) --> (Execute Script Functionality ??? to call another processor group ) Processor Group (Delete mongo)-->ExecuteStreamCommad
... View more
Labels:
- Labels:
-
Apache NiFi
06-29-2018
07:25 PM
Hi I was loaded Josn data to Elastic search by using PutElasticsearchHttpRecord record processor . How to validate number of records loaded in elastic search using nifi processor after the load. I was try to use Queryelasticsearch procesor but not get any proper results .Appreciate for your help on this issue
... View more
Labels:
- Labels:
-
Apache NiFi
06-20-2018
04:17 AM
Hi Is there any possibility to use mongodb aggregate query in getmongo processors . If not what is the alternatives Please suggest I am using mentioend query in get mongo processor. This query rran with out any issues in mongo db . while supplying htis query in nifi gave below error db.Pdtata.aggregate( {$match: {project:"ABC"}}, {$group: {_id : {d:"$projectid",c:"$caseid"}, subtotal:{$sum:1}} }, {$group: {_id:"$_id.d", caseid:{$push:{caseid:"$_id.c", subtotal:"$subtotal"}}, total:{$sum:"$subtotal"}} } ) error 00:09:00 EDT
ERROR
1b581f0a-0164-1000-9009-b7a133d91f95 GetMongoFailed to execute query Document{{$match=Document{{project:ABC}}}} due to Query failed with error code 2 and error message 'unknown top level operator: $match' on server com.mongodb.MongoQueryException: Query failed with error code 2 and error message 'unknown top level operator: $match' on
... View more
Labels:
- Labels:
-
Apache NiFi
06-20-2018
12:47 AM
Hi @Vinicius Higa Murakami Thanks for your time and support . Your solution is help full to me . here we are running on windows machine . I was used below flow but it was not working Getmongo->update attribute->queryrecord->mergecontent-> query record(this was not working) -->putfile flowfile structure(Json file) { projectshortname:AAAA projectid:5885858 caseid:1111 }, { projectshortname:BBBB projectid:5885858 caseid:222222 } query record used below query with prj
as
(
select projectshortname,projectid,caseid, count(caseid) as cnt
FROM FLOWFILE group by projectshortname,projectid,caseid
)
select projectshortname,projectid,caseid, cnt, SUM(cnt) OVER () AS total_records
from prj order by caseid mergecontent- used for combining all flow files queryrecord: applying query record for the consolidated file but this was not working all the records in the file
... View more
06-19-2018
01:38 AM
Thanks for your response. . But how to get count of one field from json file. for Example : file has empid,deptid,salary fields , how to get total records and number of employees from each department Apreciate your time and help
... View more
06-19-2018
01:38 AM
Thanks for your response. . But how to get count of one field from json file. for Example : file has empid,deptid,salary fields , how to get total records and number of employees ? Apreciate your time and help
... View more