Как написать pythoncode в процессоре ExecuteScript в apache nifi? - PullRequest
Новая
       16

Как написать pythoncode в процессоре ExecuteScript в apache nifi?

0 голосов
/ 20 июня 2019

Привет, я должен выполнить код ниже python в apache nifi, и мой поток nifi такой же, как и ниже, мой код python, как показано ниже (я испортил его локально, он работает нормально) `

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)

и мойпоток nifi: - enter image description here

Здесь cdr поступает из GETSFTP, а метки - из обработчика файла get, и здесь данные cdr будут поступать непрерывно

Может кто-нибудь помочь мне написатьприведенный выше код Python в процессоре ExecuteScript в nifi

1 Ответ

0 голосов
/ 20 июня 2019

Процессор ExecuteScript не может использовать собственные модули Python , только код Jython . Попробуйте использовать ExecuteStreamCommand для запуска произвольного кода Python.

...