Använd ett dataflöde i en pipeline

I den här handledningen bygger du en pipeline för att flytta OData från en Northwind-källa till ett lakehouse-mål och skickar ett e-postmeddelande när pipeline är slutförd.

Förutsättningar

För att komma igång måste du uppfylla följande krav:

Skapa ett sjöhus

Till att börja med måste du först skapa ett sjöhus. Ett sjöhus är en datasjö som är optimerad för analys. I den här självstudien skapar du ett sjöhus som används som mål för dataflödet.

  1. Gå till din Fabric-aktiverade arbetsyta.

    Skärmbild av den Fabric-aktiverade arbetsytan markerad.

  2. Välj Lakehouse i menyn skapa.

    Skärmbild av menyn Skapa med Create Lakehouse framhävt.

  3. Ange ett namn för lakehouse.

  4. Välj Skapa.

Nu har du skapat ett sjöhus och nu kan du konfigurera dataflödet.

Skapa ett dataflöde

Ett dataflöde är en återanvändbar datatransformering som du kan använda i en pipeline. I den här självstudien skapar du ett dataflöde som hämtar data från en OData-källa och skriver data till en lakehouse-destination.

  1. Gå till din Fabric-aktiverade arbetsyta.

    Skärmbild av den Fabric-aktiverade arbetsytan.

  2. Välj Dataflöde Gen2 på skapa-menyn.

    Skärmbild av valet Dataflöde Gen2 under den nya menyn.

  3. Mata in data från OData-källan.

    1. Välj Hämta data och välj sedan Mer.

      Skärmbild av menyn Hämta data med Mer framhävt.

    2. Från Välj datakälla söker du efter OData och väljer sedan OData-anslutningsappen.

      Skärmbild av menyn Hämta data med OData framhävd.

    3. Ange URL:en för OData-källan. I den här självstudien använder du OData-exempeltjänsten.

    4. Välj Nästa.

    5. Välj den entitet som du vill mata in. I den här självstudien använder du entiteten Orders.

      Skärmbild av förhandsversionen av OData.

    6. Välj Skapa.

Nu när du har matat in data från OData-källan kan du konfigurera lakehouse-målet.

Så här importerar du data till lakehouse-målet:

  1. Välj Lägg till datamål.

  2. Välj Lakehouse.

    Skärmbild av menyn Lägg till utdatamål med lakehouse markerat.

  3. Konfigurera den anslutning som du vill använda för att ansluta till lakehouse. Standardinställningarna är bra.

  4. Välj Nästa.

  5. Gå till arbetsytan där du skapade lakehouset.

  6. Välj det sjöhus som du skapade i föregående steg.

    Skärmbild av det valda sjöhuset.

  7. Bekräfta tabellnamnet.

  8. Välj Nästa.

  9. Bekräfta uppdateringsmetoden och välj Spara inställningar.

    Skärmbild av uppdateringsmetoderna med ersätt valt.

  10. Publicera dataflödet.

    Viktigt!

    När den första Dataflow Gen2 skapas på en arbetsyta etableras Lakehouse- och Warehouse-objekten tillsammans med deras relaterade SQL-analysslutpunkter och semantiska modeller. Dessa objekt delas av alla dataflöden på arbetsytan och krävs för att Dataflow Gen2 ska fungera, bör inte tas bort och är inte avsedda att användas direkt av användare. Objekten är en implementeringsinformation för Dataflow Gen2. Objekten är inte synliga i arbetsytan, men kan vara tillgängliga i andra upplevelser, såsom Notebook, SQL-endpointen, Lakehouse och Warehouse-upplevelserna. Du kan känna igen objekten med deras prefix i namnet. Prefixet för objekten är "DataflowsStaging".

Nu när du har matat in data till lakehouse-målet kan du konfigurera din pipeline.

Skapa en processkedja

En pipeline är ett arbetsflöde som kan användas för att automatisera databearbetning. I den här handledningen skapar du en pipeline som kör Dataflow Gen2 som du skapade i den tidigare proceduren.

  1. Gå tillbaka till översiktssidan för arbetsytan och välj Pipelines på menyn Skapa.

    Skärmbild av pipelinevalet.

  2. Ange ett namn för pipelinen.

  3. Välj dataflödesaktiviteten.

    Skärmbild av dataflödesaktiviteten som framhävs.

  4. Välj det dataflöde som du skapade i föregående procedur i listrutan Dataflöde under Inställningar.

    Skärmdump av listrutan för dataflöde.

  5. Lägg till en Office 365 Outlook-aktivitet .

    Skärmbild som betonar hur du väljer en Office 365 Outlook-aktivitet.

  6. Konfigurera Office 365 Outlook-aktiviteten för att skicka e-postaviseringar.

    1. Autentisera med ditt Office 365-konto.

    2. Välj den e-postadress som du vill skicka meddelandet till.

    3. Ange ett ämne för e-postmeddelandet.

    4. Ange en meddelandetext för e-postmeddelandet.

      Skärmbild som visar aktivitetsinställningarna för Office 365 Outlook.

Kör och schemalägg pipelinjen

I det här avsnittet kör och schemalägger du din pipeline.

  1. Gå till din arbetsyta.

  2. Öppna den nedrullningsbara menyn i pipelinen som du skapade i föregående procedur och välj sedan Schema.

    Skärmbild av pipelinemenyn med schemat framhävt.

  3. Under Schemalagd körning väljer du .

    Skärmbild som visar att en schemalagd körning är inställd på På.

  4. Ange det schema som du vill använda för att köra pipelinen.

    1. Upprepa till exempel varje dag eller varje minut.
    2. När du väljer Dagligen kan du också välja Tid.
    3. Starta ett visst datum.
    4. Avsluta ett visst datum.
    5. Välj tidszonen.
  5. Välj Använd för att tillämpa ändringarna.

Nu har du skapat en pipeline som körs enligt ett schema, uppdaterar data i lakehouse och skickar ett e-postmeddelande till dig. Du kan kontrollera status för pipelinen genom att gå till Monitor Hub. Du kan också kontrollera status för pipelinen genom att gå till Pipeline och välja fliken Körningshistorik i listrutan.