Fabric için NotebookUtils iş olayı yardımcı programları

Modülü notebookutils.businessEvents Fabric defterinden iş etkinlikleri yayınlamak için kullanın. Bir etkinlik şeması setinde tek bir etkinlik veya bir iş etkinliği şemasını takip eden bir grup etkinlik yayımlayabilirsiniz.

İş etkinliği araçları Python 3.12 ve PySpark (Python) notebooklarında mevcuttur.

Aşağıdaki tablo mevcut yöntemleri listeler:

Method Signature Description
help help(methodName: str = '') -> None Modül veya belirtilen yöntem için yardım gösterir.
publish publish(eventSchemaSetWorkspace: str, eventSchemaSet: str, eventTypeName: str, eventData: Union[Dict[str, Any], List[Dict[str, Any]]], dataVersion: str = 'v1') -> bool Belirtilen etkinlik türüne uygun bir veya daha fazla iş etkinliği yayınlar.

Yardım alın

Modülün genel bir özetini almak için aşağıdaki komutu çalıştırın:

notebookutils.businessEvents.help()

publish yöntemiyle ilgili yardım almak için yöntem adını belirtin:

notebookutils.businessEvents.help("publish")

Bir iş etkinliği yayınlayın

Note

Bölgeler arasında iş etkinliklerinin yayımlanması desteklenmektedir. Yayıncı öğesinin, iş etkinliğini içeren Olay Şeması Seti öğesiyle aynı bölgede olması gerekmez. Mevcut izinler ve ağ erişim gereksinimleri hâlâ geçerlidir.

Bir iş olayının şemasına uyan bir yük göndermek için kullanılır publish() :

published = notebookutils.businessEvents.publish(
    eventSchemaSetWorkspace="ContosoWorkspace",
    eventSchemaSet="OrderEvents",
    eventTypeName="OrderDelayed",
    eventData={
        "orderId": "12345",
        "status": "delayed",
        "reason": "weather"
    },
    dataVersion="v1"
)

print(f"Published: {published}")

Aşağıdaki tabloda parametreler açıklanmaktadır:

Parameter Türü Description
eventSchemaSetWorkspace String Olay şeması setini içeren çalışma alanının adı veya kimliği.
eventSchemaSet String Etkinlik şeması setinin adı veya kimliği.
eventTypeName String Yayınlanacak iş etkinliği türünün adı.
eventData Sözlük veya sözlükler listesi Olay yükü. Her sözlük, seçilen iş etkinliği şemasına uygun olmalıdır.
dataVersion String İş etkinliği şemasının versiyonu. Varsayılan değer: v1.

Yöntem, olay başarıyla yayımlandığında True döndürür. Etkinlik yayınlanamazsa, yöntem bir istisna çıkarır.

Birden fazla iş etkinliği yayınlayın

Aynı türden birden fazla olay yayınlamak için bir sözlük listesini şu eventDataadrese iletebilirsiniz:

published = notebookutils.businessEvents.publish(
    eventSchemaSetWorkspace="ContosoWorkspace",
    eventSchemaSet="OrderEvents",
    eventTypeName="OrderDelayed",
    eventData=[
        {
            "orderId": "12345",
            "status": "delayed",
            "reason": "weather"
        },
        {
            "orderId": "12346",
            "status": "delayed",
            "reason": "traffic"
        }
    ],
    dataVersion="v1"
)

print(f"Published: {published}")

Listedeki tüm yükler, belirtilen dataVersionşema sürümüne uygun olmalıdır.

Değerlendirmeler

  • Olayları yayınlamadan önce iş etkinliği türünü ve şemasını bir defterden oluşturun.
  • eventSchemaSetWorkspace ve eventSchemaSet için adlar veya kimlikler kullanın.
  • Özellik adlarını, veri türlerini ve gerekli alanları eventData seçilen şema sürümüne eşleştirin.
  • publish() kaynaklı özel durumları işleyin; böylece notebook ve pipeline çalıştırmaları yayımlama başarısızlıklarını raporlasın.

İlgili içerik

  • Son güncelleştirme: