Apache NiFi - Bộ xử lý tùy chỉnh
Apache NiFi là một nền tảng mã nguồn mở và cung cấp cho các nhà phát triển các tùy chọn để thêm bộ xử lý tùy chỉnh của họ trong thư viện NiFi. Làm theo các bước sau để tạo bộ xử lý tùy chỉnh.
Tải xuống phiên bản mới nhất của Maven từ liên kết dưới đây.
https://maven.apache.org/download.cgi
Thêm một biến môi trường có tên là M2_HOME và đặt giá trị làm thư mục cài đặt của maven.
Tải xuống Eclipse IDE từ liên kết bên dưới.
https://www.eclipse.org/downloads/download.php
Mở dấu nhắc lệnh và thực hiện lệnh Maven Archetype.
> mvn archetype:generate
Tìm kiếm kiểu nifi trong các dự án nguyên mẫu.
Chọn org.apache.nifi: nifi-processor-pack-archetype project.
Sau đó, từ danh sách các phiên bản, hãy chọn phiên bản mới nhất tức là 1.7.1 cho hướng dẫn này.
Nhập groupId, tạo tác, phiên bản, gói và tên tạo tác, v.v.
Sau đó, một dự án maven sẽ được tạo ra với các thư mục.
nifi-<artifactBaseName>-processors
nifi-<artifactBaseName>-nar
Chạy lệnh dưới đây trong thư mục nifi- <artifactBaseName> -processors để thêm dự án vào nhật thực.
mvn install eclipse:eclipse
Mở nhật thực và chọn nhập từ menu tệp.
Sau đó chọn “Dự án hiện có vào không gian làm việc” và thêm dự án từ thư mục nifi- <artifactBaseName> -processors trong eclipse.
Thêm mã của bạn vào chức năng public void onTrigger (ProcessContext context, ProcessSession session), chạy khi một bộ xử lý được lên lịch chạy.
Sau đó, đóng gói mã vào tệp NAR bằng cách chạy lệnh được đề cập bên dưới.
mvn clean install
Tệp NAR sẽ được tạo tại nifi-
-nar / thư mục đích. Sao chép tệp NAR vào thư mục lib của Apache NiFi và khởi động lại NiFi.
Sau khi khởi động lại NiFi thành công, hãy kiểm tra danh sách bộ xử lý để biết bộ xử lý tùy chỉnh mới.
Đối với bất kỳ lỗi nào, hãy kiểm tra tệp ./logs/nifi.log.