Apache NiFi - İşlemciler

Apache NiFi işlemcileri, veri akışı oluşturmanın temel bloklarıdır. Her işlemcinin, çıktı akış dosyasının oluşturulmasına katkıda bulunan farklı işlevleri vardır. Aşağıdaki resimde gösterilen veri akışı, GetFile işlemcisini kullanarak bir dizinden dosya alıyor ve PutFile işlemcisini kullanarak başka bir dizinde depoluyor.

Dosyayı al

GetFile işlemi, belirli bir formattaki dosyaları belirli bir dizinden almak için kullanılır. Ayrıca, getirme üzerinde daha fazla kontrol için kullanıcıya başka seçenekler de sağlar. Bunu aşağıdaki özellikler bölümünde tartışacağız.

GetFile Ayarları

Aşağıda GetFile işlemcisinin farklı ayarları verilmiştir -

İsim

Ad ayarında, bir kullanıcı projeye göre veya buna göre işlemciler için herhangi bir ad tanımlayabilir, bu da adı daha anlamlı hale getirir.

etkinleştirme

Bir kullanıcı bu ayarı kullanarak işlemciyi etkinleştirebilir veya devre dışı bırakabilir.

Ceza Süresi

Bu ayar, kullanıcının akış dosyası arızası durumunda ceza süresi süresini eklemesine izin verir.

Verim Süresi

Bu ayar, işlemcinin üretim süresini belirtmek için kullanılır. Bu süre içinde süreç tekrar programlanmaz.

Bülten Seviyesi

Bu ayar, o işlemcinin günlük seviyesini belirlemek için kullanılır.

İlişkileri Otomatik Olarak Sonlandırın

Bu, söz konusu sürecin mevcut tüm ilişkilerinin bir kontrol listesine sahiptir. Kutuları işaretleyerek, bir kullanıcı işlemciyi bu olayda akış dosyasını sonlandıracak ve akışta daha fazla göndermeyecek şekilde programlayabilir.

GetFile Planlama

Bunlar GetFile işlemcisi tarafından sunulan aşağıdaki planlama seçenekleridir -

Planlama Stratejisi

Bir CRON sürücüsü seçeneği belirleyerek, sürülen süreyi veya belirli bir CRON dizesini seçerek süreci zaman temelinde planlayabilirsiniz.

Eşzamanlı Görevler

Bu seçenek, bu işlemci için eşzamanlı görev programını tanımlamak için kullanılır.

Yürütme

Bir kullanıcı, bu seçeneği kullanarak işlemcinin tüm düğümlerde mi yoksa yalnızca Birincil düğümde mi çalıştırılacağını tanımlayabilir.

Programı Çalıştır

Zaman odaklı strateji için zamanı veya CRON güdümlü strateji için CRON ifadesini tanımlamak için kullanılır.

GetFile Özellikleri

GetFile, aşağıdaki resimde gösterildiği gibi, Giriş dizini ve Dosya Filtresi gibi Zorunlu Özellikler Yol Filtresi ve Maksimum dosya Boyutu gibi isteğe bağlı özelliklere sahiptir. Bir kullanıcı, bu özellikleri kullanarak dosya getirme sürecini yönetebilir.

GetFile Yorumları

Bu Bölüm, işlemci hakkındaki herhangi bir bilgiyi belirtmek için kullanılır.

PutFile

PutFile işlemcisi, dosyayı veri akışından belirli bir konuma depolamak için kullanılır.

PutFile Ayarları

PutFile işlemcisi aşağıdaki ayarlara sahiptir -

İsim

Ad ayarında, bir kullanıcı projeye göre veya adı daha anlamlı kılan işlemciler için herhangi bir ad tanımlayabilir.

etkinleştirme

Bir kullanıcı bu ayarı kullanarak işlemciyi etkinleştirebilir veya devre dışı bırakabilir.

Ceza Süresi

Bu ayar, kullanıcının akış dosyası arızası durumunda ceza süresi süresini eklemesine izin verir.

Verim Süresi

Bu ayar, işlemcinin üretim süresini belirtmek için kullanılır. Bu süre içerisinde süreç tekrar planlanmaz.

Bülten Seviyesi

Bu ayar, o işlemcinin günlük seviyesini belirlemek için kullanılır.

İlişkileri Otomatik Olarak Sonlandırın

Bu ayarlar, söz konusu sürecin mevcut tüm ilişkilerinin bir kontrol listesine sahiptir. Kutuları işaretleyerek, kullanıcı işlemciyi bu olayda akış dosyasını sonlandıracak ve akışta daha fazla göndermeyecek şekilde programlayabilir.

PutFile Planlama

Bunlar, PutFile işlemcisi tarafından sunulan aşağıdaki planlama seçenekleridir -

Planlama Stratejisi

Süreci, CRON sürücüsü seçeneğini seçerek zamanlayıcıyla çalıştırılan veya belirli bir CRON dizesini seçerek zaman temelinde programlayabilirsiniz. İşlemciyi belirli bir olayda tetikleyecek olan Deneysel bir Olay Odaklı strateji de vardır.

Eşzamanlı Görevler

Bu seçenek, bu işlemci için eşzamanlı görev programını tanımlamak için kullanılır.

Yürütme

Kullanıcı, bu seçeneği kullanarak işlemcinin tüm düğümlerde mi yoksa yalnızca birincil düğümde mi çalıştırılacağını tanımlayabilir.

Programı Çalıştır

Zamanlayıcı odaklı strateji için zamanı veya CRON güdümlü strateji için CRON ifadesini tanımlamak için kullanılır.

PutFile Özellikleri

PutFile işlemcisi, dosya aktarımı amacıyla çıktı dizinini belirtmek için Dizin ve aşağıdaki resimde gösterildiği gibi aktarımı yönetmek için diğerleri gibi özellikler sağlar.

PutFile Yorumları

Bu Bölüm, işlemci hakkındaki herhangi bir bilgiyi belirtmek için kullanılır.