İşlem hatlarında kullanıcı veri işlevleri etkinliği oluşturma ve çalıştırma

Doku işlem hattına kullanıcı veri işlevleri etkinliği ekleyerek özel Python işlevlerinizi otomatik veri iş akışlarının bir parçası olarak çalıştırın. Bu tümleştirme, iş mantığını işlevlerde merkezileştirmenize ve zamanlanmış ETL işlemleri sırasında çağırmanıza olanak sağlayarak not defterleri ve betikler arasında kod yineleme gereksinimini ortadan kaldırır.

İşlem hatlarında işlevler ne zaman kullanılır?

İşlem hattınıza kullanıcı veri işlevi etkinliği eklemeniz gerektiğinde:

  • Veri taşıma sırasında iş kuralları uygulama: İşlem hattınızda akan verileri doğrulayın, temizleyin veya dönüştürün. Örneğin, bir ambara yüklemeden önce ürün kategorilerini standart hale getirmek veya fiyatlandırma kuralları uygulamak.
  • Yeniden kullanılabilir mantığın zamanlanması: Aynı iş mantığını ayrı bir altyapı sürdürmeden belirli bir programa göre çalıştırın.

Önkoşullar

Başlamak için aşağıdaki önkoşulları tamamlamanız gerekir:

İşlevler etkinliğini bir işlem hattına ekleme

Yapı işlem hatları, veri taşıma ve dönüştürme etkinliklerini düzenlemeye yönelik görsel bir yol sağlar. Bu bölümde bir işlem hattı oluşturacak ve buna bir İşlevler etkinliği ekleyebilirsiniz. Sonraki bir bölümde, etkinliği özellikle kullanıcı verileri işlevleri için yapılandıracaksınız.

Functions etkinliği kullanarak işlem hattı oluşturmak için:

  1. Çalışma alanınızda + Yeni öğe seçin.

  2. Yeni öğe iletişim kutusunda Boruhattı arayın ve seçin.

  3. Yeni işlem hattı iletişim kutusunda işlem hattı için bir ad girin ve Oluştur'u seçin.

  4. İşlem hattı giriş sayfasında Etkinlikler sekmesini seçin.

  5. Diğer etkinlikleri görmek için Etkinlikler şeridinde ... (üç nokta) simgesini seçin.

  6. Orchestrate altındaki etkinlikler listesinde İşlevler'i arayın, ardından işlev etkinliğini işlem hattı tuvaline eklemek için bu işlevi seçin.

    İşlev etkinliğini bulmayı gösteren ekran görüntüsü.

Kullanıcı verileri işlevleri için etkinliği yapılandırma

İşlevler etkinliğini tuvale ekledikten sonra, kullanıcı verileri işlevinizi çağıracak şekilde yapılandırın.

Genel ayarları yapılandırma

  1. Tuvaldeki işlevler etkinliğini seçin.

  2. Genel sekmesini seçin.

  3. Etkinlik için bir İsim girin.

    İşlev etkinliği için genel ayarları gösteren ekran görüntüsü.

  4. İsteğe bağlı olarak, yeniden deneme ayarlarını yapılandırın ve güvenli giriş mi yoksa çıkış mı geçireceğinizi belirtin.

İşlev ayarlarını yapılandırma

  1. Ayarlar sekmesini seçin.

  2. Fabric kullanıcı veri işlevleri'ni Tür olarak seçin.

  3. Bağlantı açılan listesinde, kullanmak istediğiniz bağlantıyı seçin. İstediğiniz bağlantıyı görmüyorsanız Tümüne gözat'ı seçin.

  4. Başlamak için bir veri kaynağı seçin iletişim kutusunda Kullanıcı Verileri İşlevleri'ni arayın ve seçin. Bunu Yeni kaynaklar altında listelenmiş olarak görmeniz gerekir.

  5. Veri kaynağına bağlan iletişim kutusunda, varsayılan bağlantı adını ve kimlik bilgilerini koruyabilirsiniz. Oturum açtığınızdan emin olun ve Bağlan'ı seçin.

    Bağlantı bölmesinde Kullanıcı Verileri İşlevleri'ni seçme işleminin ekran görüntüsü.

    Uyarı

    Zaten bir bağlantınız varsa, iletişim kutusunda önceden seçilmiş olabilir. Yeni bir bağlantı oluşturmak için mevcut bağlantıyı tutabilir veya açılan listeden Yeni bağlantı oluştur'u seçebilirsiniz.

  6. Etkinlik ayarlarına geri dönüp Bağlantı açılır listesinden UserDataFunctions'ı seçin. Bu, yeni oluşturduğunuz bağlantıdır.

    UserDataFunctions bağlantısını seçme işleminin ekran görüntüsü.

  7. Kullanıcı verileri işlevlerinizi içeren Çalışma Alanı öğesini seçin.

  8. Kullanıcı verileri işlevleri öğe adını seçin.

  9. Çağırmak istediğiniz İşlevi seçin.

  10. Seçtiğiniz işlev için giriş parametreleri sağlayın. İşlem hattı ifadelerinden statik değerler veya dinamik içerik kullanabilirsiniz.

    İşlev etkinliği ayarlarını gösteren ekran görüntüsü.

    Uyarı

    Dinamik içerik girmek için, doldurmak istediğiniz alanı seçin ve ardından Alt+Shift+D tuşlarına basarak ifade oluşturucusunu açın.

Dinamik parametreleri geçirme

Diğer işlem hattı etkinliklerindeki veya değişkenlerindeki değerleri işlevinize geçirmek için:

  1. Daha önce gösterilen parametrenin Değer alanı gibi dinamik içeriği destekleyen bir alan name seçin.

  2. İfade oluşturucusunu açmak için Alt+Shift+D tuşlarına basın.

  3. Önceki etkinliklerden değişkenlere, parametrelere veya çıkışlara başvurmak için işlem hattı ifadelerini kullanın. Örneğin, işlevinize bir işlem hattı parametresi geçirmek için kullanın @pipeline().parameters.PipelineName .

    İfade oluşturucusunu gösteren ekran görüntüsü.

İşlem hattı ifadeleri hakkında daha fazla bilgi için bkz. İfadeler ve işlevler.

Aşağı akış etkinliklerinde işlev çıktısı kullanma

İşlevinizin dönüş değeri etkinlik çıkışında kullanılabilir. Sonraki etkinliklerde sonucu referans almak için:

  1. İşlevler etkinliğinden sonra işlem hattınıza başka bir etkinlik ekleyin.

  2. İşlevler etkinliğini seçin ve Başarılı olduğunda çıkışını (etkinliğin sağ tarafındaki yeşil onay işareti) yeni etkinliğe sürükleyin. Bu, işlev başarıyla tamamlandıktan sonra yeni etkinliğin çalışması için bir bağımlılık oluşturur.

  3. Yeni etkinliği seçin ve dinamik içeriği destekleyen bir alan bulun.

  4. İfade oluşturucusunu açmak için Alt+Shift+D tuşlarına basın.

  5. İşlevin dönüş değerine başvurmak için ifadesini @activity('YourFunctionActivityName').output kullanın. Örneğin, işlev etkinliğinin adı Functions1 ise, çıkışına başvurmak için @activity('Functions1').output'i kullanabilirsiniz.

    Aşağı akış etkinlikleri için ifade oluşturucuyu gösteren ekran görüntüsü.

Çıkışın tam yapısı işlevinizin ne döndürdüğüne bağlıdır. Örneğin, işleviniz bir sözlük döndürürse gibi @activity('YourFunctionActivityName').output.propertyNamebelirli özelliklere erişebilirsiniz.

İşlem hattını kaydetme ve çalıştırma

İşlevler etkinliğini ve işlem hattınız için diğer etkinlikleri yapılandırdıktan sonra:

  1. İşlem hattı düzenleyicisinin üst kısmındaki Giriş sekmesini seçin.
  2. İşlem hattınızı kaydetmek için Kaydet'i seçin.
  3. İşlem hattını hemen çalıştırmak için Çalıştır'ı veya yinelenen bir zamanlama ayarlamak için Zamanla'yı seçin.

Çalıştırdıktan sonra, tuvalin altındaki Çıkış sekmesinden işlem hattı yürütmesini izleyebilir ve çalıştırma geçmişini görüntüleyebilirsiniz. Daha fazla bilgi için bkz. İşlem hattı çalışmalarını izleme.