Apache NiFi - Tạo luồng

Apache NiFi cung cấp một số lượng lớn các thành phần để giúp các nhà phát triển tạo luồng dữ liệu cho bất kỳ loại giao thức hoặc nguồn dữ liệu nào. Để tạo luồng, nhà phát triển kéo các thành phần từ thanh menu sang canvas và kết nối chúng bằng cách nhấp và kéo chuột từ thành phần này sang thành phần khác.

Nói chung, một NiFi có một thành phần lắng nghe khi bắt đầu luồng như getfile, thành phần này lấy dữ liệu từ hệ thống nguồn. Ở đầu bên kia có một thành phần phát như putfile và có các thành phần ở giữa, xử lý dữ liệu.

Ví dụ: hãy tạo một luồng, lấy một tệp trống từ một thư mục và thêm một số văn bản trong tệp đó và đặt nó vào một thư mục khác.

• Để bắt đầu, hãy kéo biểu tượng bộ xử lý vào khung NiFi và chọn bộ xử lý GetFile từ danh sách.

• Tạo một thư mục đầu vào như c:\inputdir.

• Nhấp chuột phải vào bộ xử lý và chọn cấu hình và trong tab thuộc tính, thêm Input Directory (c:\inputdir) và nhấp vào áp dụng và quay lại canvas.

• Kéo biểu tượng bộ xử lý vào canvas và chọn bộ xử lý ReplaceText từ danh sách.

• Nhấp chuột phải vào bộ xử lý và chọn cấu hình. bên trongproperties tab, thêm một số văn bản như “Hello tutorialspoint.com” trong hộp văn bản của Giá trị Thay thế và nhấp vào áp dụng.

• Đi tới tab cài đặt, chọn hộp kiểm lỗi ở bên phải, sau đó quay lại khung vẽ.

• Kết nối bộ xử lý GetFIle với ReplaceText trên mối quan hệ thành công.

• Kéo biểu tượng bộ xử lý vào canvas và chọn bộ xử lý PutFile từ danh sách.

• Tạo một thư mục đầu ra như c:\outputdir.

• Nhấp chuột phải vào bộ xử lý và chọn cấu hình. Trong tab thuộc tính, hãy thêmDirectory (c:\outputdir) và nhấp vào áp dụng và quay lại canvas.

• Đi tới tab cài đặt và chọn hộp kiểm thất bại và thành công ở phía bên phải, sau đó quay lại canvas.

• Kết nối bộ xử lý ReplaceText với PutFile trên mối quan hệ thành công.

• Bây giờ bắt đầu luồng và thêm một tệp trống trong thư mục đầu vào và bạn sẽ thấy rằng, nó sẽ chuyển đến thư mục đầu ra và văn bản sẽ được thêm vào tệp.

Bằng cách làm theo các bước trên, nhà phát triển có thể chọn bất kỳ bộ xử lý nào và thành phần NiFi khác để tạo luồng phù hợp cho tổ chức hoặc khách hàng của họ.