Apache NiFi - İşlemci Sınıflandırması
Bu bölümde, Apache NiFi'de süreç kategorizasyonu tartışacağız.
Veri Alım İşlemcileri
Veri Besleme kategorisi altındaki işlemciler, verileri NiFi veri akışına almak için kullanılır. Bunlar esas olarak apache NiFi'deki herhangi bir veri akışının başlangıç noktasıdır. Bu kategorilere ait işlemcilerden bazıları GetFile, GetHTTP, GetFTP, GetKAFKA vb.
Yönlendirme ve Arabuluculuk İşlemcileri
Yönlendirme ve Arabuluculuk işlemcileri, akış dosyalarının özniteliklerindeki veya bu akış dosyalarının içeriğindeki bilgilere göre farklı işlemcilere veya veri akışlarına yönlendirmek için kullanılır. Bu işlemciler ayrıca NiFi veri akışlarını kontrol etmekten de sorumludur. Bu kategoriye ait işlemcilerden bazıları RouteOnAttribute, RouteOnContent, ControlRate, RouteText vb.
Veritabanı Erişim İşlemcileri
Bu Veritabanı Erişimi kategorisinin işlemcileri, veri seçme veya ekleme veya veritabanından diğer SQL ifadelerini yürütme ve hazırlama becerisine sahiptir. Bu işlemciler çoğunlukla Apache NiFi'nin veri bağlantı havuzu denetleyicisi ayarını kullanır. Bu kategoriye ait işlemcilerden bazıları ExecuteSQL, PutSQL, PutDatabaseRecord, ListDatabaseTables vb.
Öznitelik Çıkarma İşlemcileri
Öznitelik Çıkarma İşlemcileri, NiFi veri akışında işlenen akış dosyası özniteliklerini çıkarmak, analiz etmek ve değiştirmekle sorumludur. Bu kategoriye ait işlemcilerden bazıları UpdateAttribute, EvaluateJSONPath, ExtractText, AttributesToJSON, vb.
Sistem Etkileşimi İşlemcileri
Sistem Etkileşimi işlemcileri, herhangi bir işletim sistemindeki işlemleri veya komutları çalıştırmak için kullanılır. Bu işlemciler ayrıca çeşitli sistemlerle etkileşim kurmak için birçok dilde komut dosyaları çalıştırır. Bu kategoriye ait işlemcilerden bazıları ExecuteScript, ExecuteProcess, ExecuteGroovyScript, ExecuteStreamCommand vb.
Veri Dönüştürme İşlemcileri
Veri Dönüşümüne ait işlemciler, akış dosyalarının içeriğini değiştirme yeteneğine sahiptir. Bunlar, bir kullanıcının HTTP işlemcisini çağırmak için bir HTTP gövdesi olarak akış dosyası göndermesi gerektiğinde normalde kullanılan bir akış dosyasının verilerini tamamen değiştirmek için kullanılabilir. Bu kategoriye ait işlemcilerden bazıları ReplaceText, JoltTransformJSON, vb.
Veri İşlemcileri Gönderme
Veri Gönderme İşlemcileri genellikle bir veri akışındaki son işlemcidir. Bu işlemciler, verileri hedef sunucuya depolamak veya göndermekle sorumludur. Verileri başarıyla depoladıktan veya gönderdikten sonra, bu işlemciler başarı ilişkisiyle akış dosyasını DÜŞÜRÜR. Bu kategoriye ait işlemcilerden bazıları PutEmail, PutKafka, PutSFTP, PutFile, PutFTP vb.
Bölme ve Toplama İşlemcileri
Bu işlemciler, bir akış dosyasında bulunan içeriği bölmek ve birleştirmek için kullanılır. Bu kategoriye ait işlemcilerden bazıları SplitText, SplitJson, SplitXml, MergeContent, SplitContent vb.
HTTP İşlemcileri
Bu işlemciler HTTP ve HTTPS çağrılarıyla ilgilenir. Bu kategoriye ait işlemcilerden bazıları InvokeHTTP, PostHTTP, ListenHTTP vb .'dir.
AWS İşlemcileri
AWS işlemcileri, Amazon web hizmetleri sistemiyle etkileşimden sorumludur. Bu kategoriye ait işlemcilerden bazıları GetSQS, PutSNS, PutS3Object, FetchS3Object vb.