Delen via

Activiteit voor gebruikersdatafuncties maken en uitvoeren in pijplijnen

Voer uw aangepaste Python-functies uit als onderdeel van geautomatiseerde gegevenswerkstromen door een gebruikersgegevens-functieactiviteit toe te voegen aan een Fabric-pijplijn. Met deze integratie kunt u bedrijfslogica centraliseren in functies en deze aanroepen tijdens geplande ETL-processen, waardoor u geen code hoeft te dupliceren tussen notebooks en scripts.

Wanneer functies in pijplijnen gebruiken

Voeg een activiteit van gebruikersgegevensfuncties toe aan uw pijplijn wanneer u het volgende moet doen:

  • Bedrijfsregels toepassen tijdens gegevensverplaatsing: Gegevens valideren, opschonen of transformeren terwijl deze door uw pijplijn stromen. U kunt bijvoorbeeld productcategorieën standaardiseren of prijsregels toepassen voordat u in een magazijn laadt.
  • Herbruikbare logica plannen: voer dezelfde bedrijfslogica uit volgens een planning zonder afzonderlijke infrastructuur te onderhouden.

Vereiste voorwaarden

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

De Functions-activiteit toevoegen aan een pijplijn

Infrastructuurpijplijnen bieden een visuele manier om activiteiten voor gegevensverplaatsing en transformatie te organiseren. In deze sectie maakt u een pijplijn en voegt u er een Functions-activiteit aan toe. In een latere sectie configureert u de activiteit specifiek voor functies voor gebruikersgegevens.

Een pijplijn maken met een Functions-activiteit:

  1. Selecteer in uw werkruimte + Nieuw item.

  2. Zoek in het dialoogvenster Nieuw item naar Pijplijn en selecteer het.

  3. Voer in het dialoogvenster Nieuwe pijplijn een naam in voor de pijplijn en selecteer Maken.

  4. Selecteer op de startpagina van de pijplijn het tabblad Activiteiten .

  5. Selecteer op het lint Activiteiten het pictogram ... (beletselteken) om meer activiteiten weer te geven.

  6. Zoek naar Functies in de lijst met activiteiten onder Orchestrate en selecteer deze om de functieactiviteit toe te voegen aan het pijplijncanvas.

    schermopname waarin wordt getoond hoe u functies kunt vinden.

De activiteit voor gebruikersgegevensfuncties configureren

Nadat u de functieactiviteit aan het canvas hebt toegevoegd, configureert u deze om de functie gebruikersgegevens aan te roepen.

Algemene instellingen configureren

  1. Selecteer de functieactiviteit op het canvas.

  2. Selecteer het tabblad Algemeen .

  3. Voer een naam in voor de activiteit.

    Schermopname met algemene instellingen voor functieactiviteit.

  4. Configureer eventueel instellingen voor opnieuw proberen en geef op of u beveiligde invoer of uitvoer doorgeeft.

Functie-instellingen configureren

  1. Selecteer het tabblad Instellingen.

  2. Selecteer Fabric-gebruikersgegevensfuncties als het type.

  3. Selecteer in de vervolgkeuzelijst Verbinding een verbinding die u wilt gebruiken. Als u de gewenste verbinding niet ziet, selecteert u Alles bladeren.

  4. Zoek in het dialoogvenster Een gegevensbron kiezen om aan de slag te gaan naar functies voor gebruikersgegevens en selecteer deze. De lijst wordt weergegeven onder Nieuwe bronnen.

  5. In het dialoogvenster Verbinding maken met gegevensbron kunt u de standaardverbindingsnaam en -referenties behouden. Zorg ervoor dat u bent aangemeld en selecteer Verbinding maken.

    Schermopname van het selecteren van gebruikersgegevensfuncties in het verbindingsvenster.

    Opmerking

    Als u al een verbinding hebt, wordt deze mogelijk vooraf geselecteerd in het dialoogvenster. U kunt de bestaande verbinding behouden of een nieuwe verbinding maken selecteren in de vervolgkeuzelijst om een nieuwe verbinding te maken.

  6. Selecteer UserDataFunctions in de vervolgkeuzelijst Verbinding in de activiteitsinstellingen. Dit is de verbinding die u zojuist hebt gemaakt.

    Schermopname van het selecteren van de UserDataFunctions-verbinding.

  7. Selecteer de werkruimte met het functie-item voor gebruikersgegevens.

  8. Selecteer de itemnaam van de gebruikersgegevensfuncties .

  9. Selecteer de functie die u wilt aanroepen.

  10. Geef invoerparameters op voor de geselecteerde functie. U kunt statische waarden of dynamische inhoud uit pijplijnexpressies gebruiken.

    schermopname met instellingen voor functieactiviteit.

    Opmerking

    Als u dynamische inhoud wilt invoeren, selecteert u het veld dat u wilt vullen en drukt u op Alt+Shift+D om de opbouwfunctie voor expressies te openen.

Dynamische parameters doorgeven

Waarden van andere pijplijnactiviteiten of variabelen doorgeven aan uw functie:

  1. Selecteer een veld dat dynamische inhoud ondersteunt, zoals het veld Waarde voor de name eerder weergegeven parameter.

  2. Druk op Alt+Shift+D om de opbouwfunctie voor expressies te openen.

  3. Gebruik pijplijnexpressies om te verwijzen naar variabelen, parameters of uitvoer van eerdere activiteiten. Gebruik @pipeline().parameters.PipelineName bijvoorbeeld om een pijplijnparameter door te geven aan uw functie.

    Schermopname van de opbouwfunctie voor expressies.

Zie Expressies en functies voor meer informatie over pijplijnexpressies.

Functie-uitvoer gebruiken in downstreamactiviteiten

De retourwaarde van uw functie is beschikbaar in de uitvoer van de activiteit. Ga als volgt te werk om te verwijzen naar de uitvoer in opvolgende activiteiten:

  1. Voeg een andere activiteit toe aan uw pijplijn na de Functions-activiteit.

  2. Selecteer de Functions-activiteit en sleep de uitvoer bij geslaagde uitvoering (het groene vinkje aan de rechterkant van de activiteit) naar de nieuwe activiteit. Hiermee wordt een afhankelijkheid gemaakt, zodat de nieuwe activiteit wordt uitgevoerd nadat de functie is voltooid.

  3. Selecteer de nieuwe activiteit en zoek een veld dat dynamische inhoud ondersteunt.

  4. Druk op Alt+Shift+D om de opbouwfunctie voor expressies te openen.

  5. Gebruik de expressie @activity('YourFunctionActivityName').output om te verwijzen naar de retourwaarde van de functie. U kunt bijvoorbeeld de naam van de functieactiviteit gebruiken Functions1@activity('Functions1').output om te verwijzen naar de uitvoer.

    Schermopname van de opbouwfunctie voor expressies voor downstreamactiviteiten.

De exacte structuur van de uitvoer is afhankelijk van wat uw functie retourneert. Als uw functie bijvoorbeeld een woordenlijst retourneert, hebt u toegang tot specifieke eigenschappen, zoals @activity('YourFunctionActivityName').output.propertyName.

De pijplijn opslaan en uitvoeren

Nadat u de Functions-activiteit en eventuele andere activiteiten voor uw pijplijn hebt geconfigureerd:

  1. Selecteer het tabblad Start boven aan de pijplijneditor.
  2. Selecteer Opslaan om uw pijplijn op te slaan.
  3. Selecteer Uitvoeren om de pijplijn onmiddellijk uit te voeren of selecteer Planning om een terugkerend schema in te stellen.

Nadat u de pijplijn heeft uitgevoerd, kunt u de pijplijnuitvoering bewaken en de uitvoeringsgeschiedenis bekijken op het Uitvoer tabblad onder het canvas. Zie Pijplijnuitvoeringen bewaken voor meer informatie.

Verwante inhoud

  • Last updated on