Apache NiFi - Membuat Arus
Apache NiFi menawarkan sejumlah besar komponen untuk membantu pengembang membuat aliran data untuk semua jenis protokol atau sumber data. Untuk membuat aliran, pengembang menyeret komponen dari bilah menu ke kanvas dan menghubungkannya dengan mengeklik dan menyeret mouse dari satu komponen ke komponen lainnya.
Umumnya, NiFi memiliki komponen pendengar di awal aliran seperti getfile, yang mendapatkan data dari sistem sumber. Di ujung lain ada komponen transmitter seperti putfile dan ada komponen di antaranya, yang memproses data.
Misalnya, mari buat aliran, yang mengambil file kosong dari satu direktori dan menambahkan beberapa teks di file itu dan meletakkannya di direktori lain.
Untuk memulai, seret ikon prosesor ke kanvas NiFi dan pilih prosesor GetFile dari daftar.
Buat direktori masukan seperti c:\inputdir.
Klik kanan pada prosesor dan pilih konfigurasi dan di tab properti tambahkan Input Directory (c:\inputdir) dan klik terapkan dan kembali ke kanvas.
Seret ikon prosesor ke kanvas dan pilih prosesor ReplaceText dari daftar.
Klik kanan pada prosesor dan pilih konfigurasi. Dalamproperties tab, tambahkan beberapa teks seperti “Hello tutorialspoint.com” di kotak teks Nilai Penggantian dan klik terapkan.
Pergi ke tab pengaturan, centang kotak kegagalan di sisi kanan, lalu kembali ke kanvas.
Hubungkan prosesor GetFIle ke ReplaceText pada hubungan sukses.
Seret ikon prosesor ke kanvas dan pilih prosesor PutFile dari daftar.
Buat direktori keluaran seperti c:\outputdir.
Klik kanan pada prosesor dan pilih konfigurasi. Di tab properti, tambahkanDirectory (c:\outputdir) dan klik terapkan dan kembali ke kanvas.
Pergi ke tab pengaturan dan centang kotak centang kegagalan dan keberhasilan di sisi kanan dan kemudian kembali ke kanvas.
Hubungkan prosesor ReplaceText ke PutFile pada hubungan sukses.
Sekarang mulai aliran dan tambahkan file kosong di direktori input dan Anda akan melihatnya, itu akan pindah ke direktori output dan teks akan ditambahkan ke file.
Dengan mengikuti langkah-langkah di atas, pengembang dapat memilih prosesor dan komponen NiFi lainnya untuk membuat aliran yang sesuai untuk organisasi atau klien mereka.