Een gegevensstroom gebruiken in een pijplijn

In deze zelfstudie bouwt u een pijplijn om OData van een Northwind-bron naar een Lakehouse-bestemming te verplaatsen en een e-mailmelding te verzenden wanneer de pijplijn is voltooid.

Vereisten

Om aan de slag te gaan, moet u aan de volgende vereisten voldoen:

Een lakehouse maken

Om te beginnen moet u eerst een lakehouse maken. Een lakehouse is een data lake die is geoptimaliseerd voor analyse. In deze zelfstudie maakt u een lakehouse dat als bestemming voor de dataflow gebruikt wordt.

  1. Ga naar uw werkruimte waarvoor Fabric is ingeschakeld.

    Schermafbeelding van de benadrukte werkruimte met Fabric ingeschakeld.

  2. Selecteer Lakehouse in het menu Maken.

    Schermopname van het menu Maken met Create Lakehouse benadrukt.

  3. Voer een naam in voor het lakehouse.

  4. Selecteer Aanmaken.

U hebt nu een lakehouse gemaakt en u kunt nu de gegevensstroom instellen.

Een gegevensstroom maken

Een gegevensstroom is een herbruikbare gegevenstransformatie die u in een pijplijn kunt gebruiken. In deze zelfstudie maakt u een gegevensstroom die gegevens ophaalt uit een OData-bron en de gegevens naar een lakehouse-bestemming schrijft.

  1. Ga naar uw werkruimte waarvoor Fabric is ingeschakeld.

    Schermopname van de werkruimte waarvoor Fabric is ingeschakeld.

  2. Selecteer Dataflow Gen2 in het menu Maken.

    Schermopname van de selectie Gegevensstroom Gen2 onder het nieuwe menu.

  3. De gegevens opnemen uit de OData-bron.

    1. Selecteer Gegevens ophalen en selecteer vervolgens Meer.

      Schermafbeelding van het menu Gegevens ophalen, waarbij Meer wordt benadrukt.

    2. Zoek in Gegevensbron kiezen naar OData en selecteer vervolgens de OData-connector.

      Schermopname van het menu Gegevens ophalen met OData benadrukt.

    3. Voer de URL van de OData-bron in. Gebruik voor deze zelfstudie de OData-voorbeeldservice.

    4. Selecteer Volgende.

    5. Selecteer de entiteit die u wilt opnemen. In deze zelfstudie gebruikt u de entiteit Orders.

      Schermopname van de OData-preview.

    6. Selecteer Aanmaken.

Nu u de gegevens uit de OData-bron hebt opgenomen, kunt u de lakehouse-bestemming instellen.

De gegevens opnemen in de lakehouse-bestemming:

  1. Selecteer Gegevensdoel toevoegen.

  2. Selecteer Lakehouse.

    Schermopname van het menu Uitvoerbestemming toevoegen met lakehouse benadrukt.

  3. Configureer de verbinding die u wilt gebruiken om verbinding te maken met het lakehouse. De standaardinstellingen zijn prima.

  4. Selecteer Volgende.

  5. Navigeer naar de werkruimte waar u het lakehouse hebt gemaakt.

  6. Selecteer het lakehouse dat u in de vorige stappen hebt gemaakt.

    Schermopname van het geselecteerde lakehouse.

  7. Bevestig de tabelnaam.

  8. Selecteer Volgende.

  9. Bevestig de updatemethode en selecteer Instellingen opslaan.

    Schermopname van de updatemethoden, waarbij vervangen is geselecteerd.

  10. Publiceer de gegevensstroom.

    Belangrijk

    Wanneer de eerste Dataflow Gen2 in een werkruimte wordt gemaakt, worden ook Lakehouse- en Warehouse-items ingericht, samen met het bijbehorende SQL-analyse-eindpunt en de semantische modellen. Deze items worden gedeeld door alle gegevensstromen in de werkruimte en zijn vereist voor gebruik van Dataflow Gen2, mogen niet worden verwijderd en zijn niet bedoeld om rechtstreeks door gebruikers te worden gebruikt. De items zijn een implementatiedetail van Dataflow Gen2. De items zijn niet zichtbaar in de werkruimte, maar zijn mogelijk toegankelijk in andere ervaringen, zoals notebook, SQL-eindpunt, Lakehouse en Warehouse. U kunt de items herkennen door hun voorvoegsel in de naam. Het voorvoegsel van de items is 'DataflowsStaging'.

Nu u de gegevens naar de lakehouse-bestemming hebt overgebracht, kunt u uw pijplijn instellen.

Een pijplijn maken

Een pijplijn is een werkstroom die kan worden gebruikt om gegevensverwerking te automatiseren. In deze zelfstudie maakt u een pijplijn waarmee de Gegevensstroom Gen2 wordt uitgevoerd die u in de vorige procedure hebt gemaakt.

  1. Ga terug naar de overzichtspagina van de werkruimte en selecteer Pijplijnen in het menu Maken.

    Schermopname van de pijplijnselectie.

  2. Geef een naam op voor de pijplijn.

  3. Selecteer de gegevensstroomactiviteit .

    Schermafbeelding van de gemarkeerde dataflow-activiteit.

  4. Selecteer de gegevensstroom die u in de vorige procedure hebt gemaakt in de vervolgkeuzelijst Gegevensstroom onder Instellingen.

    Screenshot van de vervolgkeuzelijst voor gegevensstroom.

  5. Een Office 365 Outlook-activiteit toevoegen.

    Schermopname waarin wordt benadrukt hoe u een Office 365 Outlook-activiteit selecteert.

  6. Configureer de Office 365 Outlook-activiteit om een e-mailmelding te verzenden.

    1. Verifieer met uw Office 365-account.

    2. Selecteer het e-mailadres waarnaar u de melding wilt verzenden.

    3. Voer een onderwerp in voor het e-mailbericht.

    4. Voer een hoofdtekst in voor het e-mailbericht.

      Schermopname van de activiteiteninstellingen van Office 365 Outlook.

De pijplijn uitvoeren en plannen

In deze sectie voert u de pijplijn uit en plant u deze.

  1. Ga naar uw werkruimte.

  2. Open de vervolgkeuzelijst van de pijplijn die u in de vorige procedure hebt gemaakt en selecteer Planning.

    Schermopname van het pijplijnmenu met de nadruk op planning.

  3. Bij Geplande uitvoering selecteert u Aan.

    Schermopname van geplande uitvoering ingesteld op Aan.

  4. Geef het schema op dat u wilt gebruiken om de pijplijn uit te voeren.

    1. Herhaal bijvoorbeeld elke dag of elke minuut.
    2. Wanneer u Dagelijks hebt geselecteerd, kunt u ook de tijd selecteren.
    3. Begin op een specifieke datum.
    4. Eindigt Op een specifieke Datum.
    5. Selecteer de tijdzone.

  5. Selecteer Toepassen om de wijzigingen toe te passen.

U hebt nu een pijplijn gemaakt die volgens een planning wordt uitgevoerd, de gegevens in lakehouse vernieuwt en u een e-mailmelding stuurt. U kunt de status van de pijplijn controleren door naar de Monitor Hub te gaan. U kunt ook de status van de pijplijn controleren door naar Pijplijn te gaan en het tabblad Uitvoeringsgeschiedenis in de vervolgkeuzelijst te selecteren.

Gerelateerde inhoud

  • Last updated on