Lakeflow İşleri içindeki görevlerin akışını denetleme

Bazı işler, tamamlanması gereken görevlerin listesidir. Aralarında bağımlılıklar belirterek görevlerin yürütme sırasını denetleyebilirsiniz. Görevleri sıralı veya paralel çalışacak şekilde yapılandırabilirsiniz.

Ancak koşullu görevler, hata düzeltme veya temizleme içeren dallanma akışları da oluşturabilirsiniz. Lakeflow Jobs, bir iş içindeki görevlerin akışını kontrol etmek için işlevsellik sağlar. Aşağıdaki konularda, görevlerinizin akışını denetlemenin yolları açıklanmaktadır.

Yeniden Denemeler

Yeniden denemeler, görev bir hata iletisiyle başarısız olursa belirli bir görevin kaç kez yeniden çalıştırılması gerektiğini belirtir. Hatalar genellikle geçicidir ve yeniden başlatma yoluyla çözülür. Azure Databricks'te Yapılandırılmış Akış ile şema evrimi gibi bazı özellikler, ortamı sıfırlamak ve bir iş akışının devam etmelerine izin vermek için yeniden denemelerle iş çalıştırdığınızı varsayar.

Bir görev için yeniden denemeler belirtirseniz, bir hatayla karşılaşırsa görev belirtilen sayıda yeniden başlatılır. Tüm iş yapılandırmaları görev yeniden denemelerini desteklemez. yeniden deneme ilkesi ayarlama bölümüne bakın.

Sürekli tetikleyici modunda çalışırken Databricks, üstel geri çekilme ile otomatik olarak yeniden dener. Bkz: Sürekli görevler için hata işleme.

Koşullu görevler varsa çalıştır

Görev türü Çalıştır'ı, diğer görevlerin sonucuna göre sonraki görevler için koşullar belirtmek üzere kullanabilirsiniz. İşinize görevler ekler ve yukarı akışa bağımlı görevler belirtirsiniz. Bu görevlerin durumuna bağlı olarak, çalıştırılacak bir veya daha fazla aşağı akış görevi yapılandırabilirsiniz. İşler aşağıdaki bağımlılıkları destekler:

  • Tümü başarılı oldu
  • En az biri başarılı oldu
  • Hiçbiri başarısız oldu
  • Hepsi bitti
  • En az bir başarısızlık
  • Tümü başarısız oldu

Bkz. Görev bağımlılıklarını yapılandırma

If/else koşullu görevleri

If/else görev türünü kullanarak bazı değerlere dayalı koşullu değerler belirtebilirsiniz. bkz. If/else göreviile bir işe dallanma mantığı ekleme.

Lakeflow İşleri, mantığınızda tanımladığınız taskValues ile bir görevden iş ortamına bazı hesaplama veya durum sonuçlarını geri döndürmenizi sağlar. If/else koşullarını taskValues, iş parametrelerine veya dinamik değerlere göre tanımlayabilirsiniz.

Lakeflow Jobs, koşullar için aşağıdaki operatörleri destekler:

  • ==
  • !=
  • >
  • >=
  • <
  • <=

Ayrıca bkz:

Her görev için

For each görevi kullanarak bir döngüde başka bir görev çalıştırın ve görevin her yinelemesine farklı bir parametre kümesi geçirin.

Bir işe For each görevi eklemek için, For each görevi ve iç içe görev'ü tanımlamanız gerekir. İç içe geçmiş görev, her For each görevinin yinelemesinde çalıştırılacak görevdir ve standart Databricks görev türlerinden biridir. İç içe göreve parametre geçirmek için birden çok yöntem desteklenir.

Bkz. Başka bir görevi döngüde çalıştırmak için bir For each görev kullanma.

Devre dışı bırakılan görevler

Bir görevi işten kaldırmadan çalışma zamanında atlamak için devre dışı bırakın. Görev yapılandırma ve çalıştırma geçmişini korur ve Lakeflow İşleri de çalışıp çalışmadıklarını belirlemek için aşağı akış görevlerini koşullarına göre Run if değerlendirir.

Bkz. Lakeflow İşlerinde devre dışı bırakılan görevler.