NotebookUtils βοηθητικά προγράμματα επαγγελματικών εκδηλώσεων για το Fabric

Χρησιμοποιήστε τη notebookutils.businessEvents λειτουργική μονάδα για να δημοσιεύσετε επιχειρηματικά συμβάντα από ένα σημειωματάριο Fabric. Μπορείτε να δημοσιεύσετε ένα μεμονωμένο συμβάν ή μια δέσμη συμβάντων που ακολουθούν ένα σχήμα επιχειρηματικού συμβάντος σε ένα σύνολο σχήματος συμβάντων.

Τα βοηθητικά προγράμματα επιχειρηματικών εκδηλώσεων είναι διαθέσιμα σε σημειωματάρια Python 3.12 και PySpark (Python).

Ο παρακάτω πίνακας παραθέτει τις διαθέσιμες μεθόδους:

Μέθοδος Υπογραφή Περιγραφή
help help(methodName: str = '') -> None Εμφανίζει βοήθεια για τη λειτουργική μονάδα ή την καθορισμένη μέθοδο.
publish publish(eventSchemaSetWorkspace: str, eventSchemaSet: str, eventTypeName: str, eventData: Union[Dict[str, Any], List[Dict[str, Any]]], dataVersion: str = 'v1') -> bool Δημοσιεύει ένα ή περισσότερα επιχειρηματικά συμβάντα στον καθορισμένο τύπο συμβάντος.

Λάβετε βοήθεια

Εκτελέστε την ακόλουθη εντολή για να λάβετε μια επισκόπηση της λειτουργικής μονάδας:

notebookutils.businessEvents.help()

Για να λάβετε βοήθεια για τη publish μέθοδο, καθορίστε το όνομα της μεθόδου:

notebookutils.businessEvents.help("publish")

Δημοσίευση επαγγελματικής εκδήλωσης

Χρησιμοποιήστε το publish() για να στείλετε ένα φορτίο που ταιριάζει με το σχήμα ενός επιχειρηματικού γεγονότος:

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

print(f"Published: {published}")

Ο παρακάτω πίνακας περιγράφει τις παραμέτρους:

Παράμετρος Τύπος Περιγραφή
eventSchemaSetWorkspace Συμβλοσειρά Το όνομα ή το αναγνωριστικό του χώρου εργασίας που περιέχει το σύνολο σχήματος συμβάντων.
eventSchemaSet Συμβλοσειρά Το όνομα ή το αναγνωριστικό του συνόλου σχήματος συμβάντων.
eventTypeName Συμβλοσειρά Το όνομα του τύπου επιχειρηματικής εκδήλωσης που θέλετε να δημοσιεύσετε.
eventData Λεξικό ή κατάλογος λεξικών Το φορτίο συμβάντος. Κάθε λεξικό πρέπει να συμμορφώνεται με το επιλεγμένο σχήμα επιχειρηματικής εκδήλωσης.
dataVersion Συμβλοσειρά Η έκδοση του σχήματος επιχειρηματικής εκδήλωσης. Η προεπιλογή είναι v1.

Η μέθοδος επιστρέφει True όταν το συμβάν δημοσιευτεί με επιτυχία. Εάν το συμβάν δεν μπορεί να δημοσιευτεί, η μέθοδος δημιουργεί μια εξαίρεση.

Δημοσίευση πολλών επιχειρηματικών συμβάντων

Για να δημοσιεύσετε πολλά συμβάντα του ίδιου τύπου σε μία κλήση, μεταβιβάστε μια λίστα λεξικών στο eventData:

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}")

Όλα τα ωφέλιμα φορτία στη λίστα πρέπει να συμμορφώνονται με την έκδοση σχήματος που καθορίζεται από dataVersionτο .

Εκτιμήσεις

  • Δημιουργήστε τον τύπο επαγγελματικού συμβάντος και το σχήμα του πριν δημοσιεύσετε συμβάντα από ένα σημειωματάριο.
  • Χρησιμοποιήστε είτε ονόματα είτε αναγνωριστικά για eventSchemaSetWorkspace και eventSchemaSet.
  • Αντιστοιχίστε τα ονόματα ιδιοτήτων, τους τύπους δεδομένων και τα απαιτούμενα πεδία eventData με την επιλεγμένη έκδοση σχήματος.
  • Χειρισμός εξαιρέσεων από publish() έτσι ώστε το σημειωματάριο και η διοχέτευση να εκτελούν αποτυχίες δημοσίευσης αναφορών.

Σχετικό περιεχόμενο

  • Last updated on