How to write pythoncode in ExecuteScript processor in apache nifi?

Question

Hi I have to execute below python code in apache nifi and my nifi flow is as below  my python code is as below (I have ruined it locally it is working fine)  `

import pandas as pd
 cdr = pd.read_csv("cdr.csv")
 labels = pd.read_csv("result.csv")
 cdr.rename(mapper={str(value[0]):n for n,value in labels.to_dict(orient='list').items()},  axis=1, inplace=True)

and my nifi flow :-

Here cdr comes from GETSFTP and labels comes from get file processor and here cdr data will come continuously

can anyone help me to write above python code in ExecuteScript processor in nifi

it will be easier to use ExecuteStreamCommand - it allows to read from STDIN and write to STDOUT. but in this case python must be installed near nifi. if you still want to use ExecuteScript I advice you to start from this article: community.hortonworks.com/articles/75032/… — daggett
– daggett, Commented Jun 20, 2019 at 7:37

Andy · Accepted Answer · 2019-06-20 08:41:37Z

0

The ExecuteScript processor cannot use native Python modules, only Jython code. Try using ExecuteStreamCommand to run arbitrary Python code.

answered Jun 20, 2019 at 8:41

Andy

14.2k2 gold badges38 silver badges80 bronze badges

Sign up to request clarification or add additional context in comments.

Collectives™ on Stack Overflow

How to write pythoncode in ExecuteScript processor in apache nifi?

1 Answer 1

Comments

Your Answer

Linked

Hot Network Questions

Collectives™ on Stack Overflow

1 Answer 1

Comments

Your Answer

Sign up or log in

Post as a guest

Linked

Related