Hadoop'ta Oozie İş Akışlarını Planlama ve Koordine Etme -

2024

Bir iş akışı kümesi oluşturduktan sonra, ne zaman ne zaman çalışacaklarını planlamak için bir dizi Oozie koordinatörü işi kullanabilirsiniz idam. Yürütme için iki zamanlama seçeneğiniz var: belirli bir süre ve belirli bir süreyle birlikte verilerin kullanılabilirliği.

Oozie koordinatörü işleri için zamana dayalı planlama

Oozie koordinatörü işleri belli bir zamanda yürütülmek üzere planlanabilir, ancak başlatıldıktan sonra belirli aralıklarla çalışacak şekilde yapılandırılabilirler. Aşağıdaki örnek, belirtilen başlangıç ​​saat ve tarihte çalışmaya başlayan bir koordinatör işini gösterir:

… $ {workflowAppPath}

Oozie koordinatörü işleri için zaman ve veri kullanılabilirlik tabanlı çizelgeleme

Oozie koordinatörü işleri aynı zamanda belirli veri dosyaları veya dizinleri mevcut. Aşağıdaki liste, belirli bir başlangıç ​​tarih ve saatinde çalışmaya başlar, triggerDatasetDir ile tanımlanan veri kümesi varsa günde bir kez çalıştırılan ve belirtilen bitiş zamanı kadar çalıştırılan bir koordinatör örneğini gösterir:

… $ {triggerDatasetDir} $ {startTime} $ {workflowAppPath}

Oozie koordinatörü işleri çalıştırma

Oozie iş akışı işlerine benzer şekilde, koordinatör işleri bir iş gerektirir. özellikler dosyası ve koordinatör. xml dosyasının HDFS'ye yüklenmesi gerekiyor. Oozie komut satırı arayüzünden bir Oozie koordinatörü işi çalıştırmak için, işi gerçekleştirirken aşağıdakiler gibi bir komut verin. özellikler dosyasına yerel olarak erişilebilir:

$ oozie job -config sampleKoordinatör / iş. properties -run

İşi gönderdikten sonra, koordinatör Oozie nesne veritabanında saklanır. Gönderim üzerine, Oozie, koordinatörünüzü - işiniz: 0000001-00000001234567-oozie-C'yi izlemenize ve yönetmenize olanak tanımak için bir tanımlayıcı döndürür.

Bu işin durumunu kontrol etmek için

oozie job -info 0000001-00000001234567-oozie-C