Een e-mailbericht verzenden met een Azure Data Factory- of Azure Synapse-pijplijn

Van toepassing op: Azure Data Factory Azure Synapse Analytics

Tip

Data Factory in Microsoft Fabric is de volgende generatie van Azure Data Factory, met een eenvoudigere architectuur, ingebouwde AI en nieuwe functies. Als u nieuw bent in gegevensintegratie, begint u met Fabric Data Factory. Bestaande ADF-workloads kunnen upgraden naar Fabric om toegang te krijgen tot nieuwe mogelijkheden voor gegevenswetenschap, realtime analyses en rapportage.

Het is vaak nodig om meldingen te verzenden tijdens of na de uitvoering van een pijplijn. Melding biedt proactieve waarschuwingen en vermindert de noodzaak van reactieve bewaking om problemen te detecteren.  In dit artikel wordt beschreven hoe u e-mailmeldingen configureert vanuit een Azure Data Factory- of Azure Synapse-pijplijn. 

Vereisten

  • Azure-abonnement. Als u geen Azure-abonnement hebt, maakt u een free-account voordat u begint.
  • Standaardwerkstroom voor logische apps. Als u het verzenden van een e-mailbericht vanuit de pijplijn wilt activeren, gebruikt u Azure Logic Apps om de werkstroom te definiëren. Zie Een standaard logische app-werkstroom maken voor meer informatie over het maken van een standaard logische app-werkstroom.

De e-mailwerkstroom maken in uw logische app

Maak een standaardwerkstroom voor logische apps met de naam SendEmailFromPipeline. Voeg de aanvraagtrigger met de naam When an HTTP request is received toe en voeg de actie Office 365 Outlook toe met de naam Send an email (V2).

Toont de Logic App-werkstroomontwerper met de Request-trigger en de E-mail verzenden (V2) actie.

Geef in aanvraagtrigger deze JSON op voor de Request Body JSON Schema eigenschap:

{
    "properties": {
        "dataFactoryName": {
            "type": "string"
        },
        "message": {
            "type": "string"
        },
        "pipelineName": {
            "type": "string"
        },
        "receiver": {
            "type": "string"
        }
    },
    "type": "object"
}

De aanvraagtrigger in de werkstroomontwerper moet er als volgt uitzien:

Toont de werkstroomontwerper voor de aanvraagtrigger met het JSON-schemaveld Aanvraagbody ingevuld.

Pas voor de actie Een e-mail verzenden (V2) aan hoe u het e-mailbericht wilt opmaken met behulp van de eigenschappen van het JSON-schema voor de hoofdtekst van de aanvraag:

Toont de werkstroomontwerper voor de actie Een e-mail verzenden (V2).

Sla de werkstroom op. Blader naar de pagina Overzicht voor de werkstroom. Noteer de werkstroom-URL, gemarkeerd in de onderstaande afbeelding:

Toont de pagina Overzicht van de werkstroom met de URL van de werkstroom gemarkeerd.

Notitie

Als u de werkstroom-URL wilt vinden, moet u naar de werkstroom zelf bladeren, niet alleen naar de logische app die deze bevat. Selecteer op de pagina Werkstromen van uw exemplaar van uw logische app de werkstroom en navigeer vervolgens naar de overzichtspagina.

Een pijplijn maken om uw werkstroom voor logische apps te activeren

Nadat u de werkstroom van de logische app hebt gemaakt om e-mail te verzenden, kunt u deze activeren vanuit een pijplijn met behulp van een webactiviteit .

  1. Maak een nieuwe pijplijn en zoek de webactiviteit onder de categorie Algemeen om deze naar het bewerkingscanvas te slepen.

  2. Selecteer de nieuwe web1-activiteit en selecteer vervolgens het tabblad Instellingen .

    Geef de URL op van de werkstroom van de logische app die u eerder in het URL-veld hebt gemaakt.

    Geef de volgende JSON op voor de hoofdtekst:

       {
    "message" : "This is a custom dynamic message from your pipeline with run ID @{pipeline().RunId}.",
    "dataFactoryName" : "@{pipeline().DataFactory}", 
    "pipelineName" : "@{pipeline().Pipeline}", 
    "receiver" : "@{pipeline().parameters.receiver}"
   }

    Gebruik dynamische expressies om nuttige berichten te genereren voor gebeurtenissen in uw pijplijnen. U ziet dat de JSON-indeling hier overeenkomt met de JSON-indeling die u in de logische app hebt gedefinieerd en u kunt deze ook naar wens aanpassen.

    Toont een pijplijn met een webactiviteit die is geconfigureerd met de werkstroom-URL van de logische app en de hoofdtekst van het JSON-bericht.

  3. Selecteer het achtergrondgebied van de ontwerpfunctie voor pijplijnen om de pagina met pijplijneigenschappen te selecteren en voeg een nieuwe parameter met de naam ontvanger toe, waarbij een e-mailadres als standaardwaarde wordt opgegeven.

    In dit voorbeeld geven we de ontvanger-e-mail op van een pijplijnparameter die we willekeurig definiëren. De ontvangerwaarde kan worden opgehaald uit elke expressie of zelfs gekoppelde gegevensbronnen.

    Toont de configuratie van de ontvangerparameter in de pijplijnontwerper.

  4. Publiceer uw pijplijn en activeer deze handmatig om te bevestigen dat het e-mailbericht wordt verzonden zoals verwacht.

    Laat zien hoe u de pijplijn handmatig activeert.

Dynamische berichten toevoegen met systeemvariabelen en expressies

U kunt systeemvariabelen en expressies gebruiken om uw berichten dynamisch te maken. Bijvoorbeeld:

  • @activity("CopyData").output.errors[0].Message

  • @activity("DataFlow").error.Message

De bovenstaande expressies retourneren de relevante foutberichten van een Copy activity-fout, die vervolgens kunnen worden omgeleid naar uw webactiviteit waarmee de e-mail wordt verzonden. Voor meer informatie raadpleegt u het artikel uitvoereigenschappen van de Copy-activiteit.

  • Last updated on