Как выполнить скрипт Python в Nifi ⚙️

Чтобы выполнить скрипт Python в Nifi, вам понадобится использовать процессор ExecuteScript. Вот пример кода, который поможет вам выполнить скрипт:

# Импортируйте необходимые модули
import sys

# Определите функцию, которую нужно выполнить
def execute_script():
    # Ваш скрипт Python здесь
    print("Пример выполнения скрипта в Nifi")

# Вызовите функцию выполнения скрипта
execute_script()
    

Как запустить скрипт Python в NiFi

Apache NiFi представляет собой мощный инструмент для обработки и переноса данных между различными источниками и назначениями. Он имеет встроенную поддержку для запуска скриптов на различных языках, включая Python. В этом статье мы рассмотрим как выполнить скрипт Python в NiFi.

Подготовка среды

Перед запуском скрипта Python в NiFi необходимо выполнить следующие шаги подготовки:

1. Установите Apache NiFi на свою систему, если вы ещё не сделали это. Вы можете найти инструкции по установке на официальном сайте NiFi.
2. Убедитесь, что на вашей системе установлен Python. NiFi поддерживает Python 2.x и Python 3.x.
3. Откройте веб-интерфейс NiFi, перейдя по адресу http://localhost:8080 в вашем браузере.

Настройка процессора ExecuteScript

Для запуска скрипта Python в NiFi мы будем использовать процессор ExecuteScript. Вот как его настроить:

1. Перетащите процессор ExecuteScript из панели инструментов в графическое представление вашего процесса.
2. Настройте свойства процессора, установив следующие значения:
   • Script Engine: Выберите "python" из выпадающего списка.
   • Script Body: Введите ваш скрипт Python в это поле.

Примеры

Вот несколько примеров скриптов Python, которые вы можете запустить в NiFi.

# Пример 1: Простой пример вывода сообщения
print("Привет, мир!")

Этот скрипт просто выводит сообщение "Привет, мир!" в консоль.

# Пример 2: Чтение данных из потока (stream)
import sys

# Чтение данных из потока
for line in sys.stdin:
    # Обработка каждой строки
    processed_line = line.strip().upper()
    print(processed_line)

В этом примере скрипт читает данные из потока и выполняет обработку каждой строки. Каждая строка затем преобразуется в верхний регистр и выводится.

Запуск процесса

После настройки процессора ExecuteScript и написания скрипта Python вы можете запустить процесс в NiFi следующим образом:

1. Щелкните правой кнопкой мыши на процессоре ExecuteScript в графическом представлении процесса.
2. Выберите "Start" в контекстном меню.

Теперь ваш скрипт Python будет запущен, и вы сможете увидеть его вывод в журнале выполнения NiFi.

Заключение

Теперь вы знаете, как выполнить скрипт Python в Apache NiFi с использованием процессора ExecuteScript. Ниже приведены некоторые примеры скриптов, которые вы можете использовать в своих процессах NiFi. Помните, что NiFi предлагает множество возможностей для манипуляции данными, и использование скриптов Python является одним из инструментов для достижения ваших целей.