Apache NiFi - การสร้างโฟลว์

Apache NiFi มีส่วนประกอบจำนวนมากเพื่อช่วยนักพัฒนาในการสร้างกระแสข้อมูลสำหรับโปรโตคอลหรือแหล่งข้อมูลประเภทใดก็ได้ ในการสร้างโฟลว์นักพัฒนาจะลากส่วนประกอบจากแถบเมนูไปยังผืนผ้าใบและเชื่อมต่อโดยคลิกและลากเมาส์จากส่วนประกอบหนึ่งไปยังอีกส่วนหนึ่ง

โดยทั่วไป NiFi จะมีส่วนประกอบของ Listener ที่จุดเริ่มต้นของโฟลว์เช่น getfile ซึ่งรับข้อมูลจากระบบต้นทาง อีกด้านหนึ่งมีส่วนประกอบของเครื่องส่งสัญญาณเช่น putfile และมีส่วนประกอบอยู่ระหว่างนั้นซึ่งประมวลผลข้อมูล

ตัวอย่างเช่นให้สร้างโฟลว์ซึ่งรับไฟล์ว่างจากไดเร็กทอรีหนึ่งและเพิ่มข้อความในไฟล์นั้นและวางไว้ในไดเร็กทอรีอื่น

  • เริ่มต้นด้วยการลากไอคอนโปรเซสเซอร์ไปที่ผ้าใบ NiFi และเลือกโปรเซสเซอร์ GetFile จากรายการ

  • สร้างไดเร็กทอรีอินพุตเช่น c:\inputdir.

  • คลิกขวาที่โปรเซสเซอร์และเลือกกำหนดค่าและในแท็บคุณสมบัติเพิ่ม Input Directory (c:\inputdir) แล้วคลิกใช้และกลับไปที่แคนวาส

  • ลากไอคอนโปรเซสเซอร์ไปที่แคนวาสและเลือกตัวประมวลผล ReplaceText จากรายการ

  • คลิกขวาที่โปรเซสเซอร์และเลือกกำหนดค่า ในproperties เพิ่มข้อความเช่น “Hello tutorialspoint.com” ในช่องข้อความของค่าทดแทนแล้วคลิกใช้

  • ไปที่แท็บการตั้งค่าเลือกช่องทำเครื่องหมายความล้มเหลวทางด้านขวามือจากนั้นกลับไปที่ผืนผ้าใบ

  • เชื่อมต่อตัวประมวลผล GetFIle กับ ReplaceText กับความสัมพันธ์ที่ประสบความสำเร็จ

  • ลากไอคอนโปรเซสเซอร์ไปที่แคนวาสและเลือกโปรเซสเซอร์ PutFile จากรายการ

  • สร้างไดเร็กทอรีเอาต์พุตเช่น c:\outputdir.

  • คลิกขวาที่โปรเซสเซอร์และเลือกกำหนดค่า ในแท็บคุณสมบัติเพิ่มDirectory (c:\outputdir) แล้วคลิกใช้และกลับไปที่แคนวาส

  • ไปที่แท็บการตั้งค่าและเลือกช่องทำเครื่องหมายความล้มเหลวและความสำเร็จทางด้านขวามือจากนั้นกลับไปที่ผืนผ้าใบ

  • เชื่อมต่อตัวประมวลผล ReplaceText กับ PutFile กับความสัมพันธ์ที่ประสบความสำเร็จ

  • ตอนนี้เริ่มโฟลว์และเพิ่มไฟล์ว่างในไดเร็กทอรีอินพุตและคุณจะเห็นว่ามันจะย้ายไปที่ไดเร็กทอรีเอาต์พุตและข้อความจะถูกเพิ่มลงในไฟล์

เมื่อทำตามขั้นตอนข้างต้นนักพัฒนาสามารถเลือกโปรเซสเซอร์และส่วนประกอบ NiFi อื่น ๆ เพื่อสร้างโฟลว์ที่เหมาะสมสำหรับองค์กรหรือไคลเอ็นต์ของตน