Kopírování dat a odesílání e-mailových oznámení o úspěchu a selhání

2025-04-04

PLATÍ PRO: Azure Data Factory Azure Synapse Analytics

Návod

Vyzkoušejte si službu Data Factory v Microsoft Fabric, řešení pro analýzy typu all-in-one pro podniky. Microsoft Fabric zahrnuje všechno od přesunu dat až po datovou vědu, analýzy v reálném čase, business intelligence a reportování. Přečtěte si, jak začít používat novou zkušební verzi zdarma.

V tomto kurzu vytvoříte kanál služby Data Factory, který prezentuje některé funkce řízení toku. Tento kanál provádí jednoduché kopírování z kontejneru ve službě Azure Blob Storage do jiného kontejneru ve stejném účtu úložiště. Pokud aktivita kopírování proběhne úspěšně, kanál odešle podrobnosti o úspěšném kopírování (jako je například množství zapsaných dat) v e-mailu informujícím o úspěchu. Pokud aktivita kopírování selže, kanál odešle podrobnosti o neúspěšném kopírování (jako je například chybová zpráva) v e-mailu informujícím o selhání. V rámci tohoto kurzu se dozvíte, jak předávat parametry.

Základní přehled scénáře: Diagram znázorňuje službu Azure Blob Storage, který je cílem kopírování; při úspěchu odešle e-mail s podrobnostmi nebo při selhání odešle e-mail s podrobnostmi o chybě.

V tomto kurzu provedete následující kroky:

Vytvoření datové továrny
Vytvoření propojené služby Azure Storage
Vytvoření datové sady Azure Blob
Vytvořte datový kanál, který obsahuje aktivitu kopírování a webovou aktivitu.
Odeslání výstupů aktivit následným aktivitám
Využití předávání parametrů a systémových proměnných
Spustit potrubí
Monitorování kanálu a spuštění aktivit

Tento kurz používá Azure Portal. K interakci s Azure Data Factory můžete použít jiné mechanismy, podívejte se na část "Rychlé starty" v obsahu.

Požadavky

Předplatné Azure. Pokud ještě nemáte předplatné Azure, vytvořte si napřed bezplatný účet.
Účet služby Azure Storage. Úložiště objektů blob použijete jako zdrojové úložiště dat. Pokud nemáte účet úložiště Azure, přečtěte si článek Vytvoření účtu úložiště, kde najdete kroky pro jeho vytvoření.
Azure SQL Database Tuto databázi použijete jako úložiště dat jímky. Pokud ve službě Azure SQL Database nemáte databázi, přečtěte si článek Vytvoření databáze ve službě Azure SQL Database , kde najdete postup jeho vytvoření.

Vytvořte tabulku blob

Spusťte Poznámkový blok. Zkopírujte následující text a uložte ho na disk jako soubor input.txt.
```
John,Doe
Jane,Doe
```
Pomocí nástroje, jako je například Průzkumník služby Azure Storage, proveďte následující kroky:
1. Vytvořte kontejner adfv2branch.
2. V kontejneru adfv2branch vytvořte vstupní složku.
3. Nahrajte do kontejneru soubor input.txt.

Vytvoření koncových bodů pracovního postupu pro e-maily

K aktivaci odesílání e-mailů z kanálu použijete Azure Logic Apps k definování pracovního postupu. Další informace o vytvoření pracovního postupu aplikace logiky najdete v tématu Vytvoření ukázkového pracovního postupu aplikace logiky Consumption.

Pracovní postup úspěšné e-mailové kampaně

Vytvořte pracovní postup aplikace logiky Consumption s názvem CopySuccessEmail. Přidejte trigger požadavku s názvem Při přijetí požadavku HTTP a přidejte akci Office 365 Outlook s názvem Odeslat e-mail. Pokud se zobrazí výzva, přihlaste se ke svému účtu Office 365 Outlook.

Ukazuje snímek obrazovky pracovního postupu e-mailu nazvaného 'Success'.

V případě triggeru požadavku vyplňte do pole JSON schéma těla požadavku následující kód JSON:

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

Trigger požadavku v návrháři pracovního postupu by měl vypadat jako na následujícím obrázku:

Zobrazuje snímek obrazovky návrháře pracovního postupu s triggerem požadavku.

V případě akce Odeslat e-mail upravte způsob formátování e-mailu pomocí vlastností předaných ve schématu JSON textu požadavku. Zde je příklad:

Zobrazuje snímek obrazovky návrháře pracovního postupu s akcí s názvem Odeslat e-mail.

Uložte pracovní postup. Poznamenejte si adresu URL žádosti HTTP Post pro pracovní postup úspěšných e-mailů.

//Success Request Url
https://prodxxx.eastus.logic.azure.com:443/workflows/000000/triggers/manual/paths/invoke?api-version=2016-10-01&sp=%2Ftriggers%2Fmanual%2Frun&sv=1.0&sig=000000

Pracovní postup pro e-maily s informací o neúspěchu

Stejným postupem vytvořte jiný pracovní postup aplikace logiky s názvem CopyFailEmail. V triggeru požadavku zůstává hodnota zadaná ve schématu JSON textu požadavku stejná. Změňte formát svého e-mailu, jako je Subject, aby odpovídal e-mailu o selhání. Zde je příklad:

Zobrazuje snímek obrazovky návrháře pracovního postupu s neúspěšným e-mailovým pracovním postupem.

Uložte pracovní postup. Poznamenejte si adresu URL žádosti HTTP Post pro pracovní postup pro e-maily s informací o neúspěchu:

//Fail Request Url
https://prodxxx.eastus.logic.azure.com:443/workflows/000000/triggers/manual/paths/invoke?api-version=2016-10-01&sp=%2Ftriggers%2Fmanual%2Frun&sv=1.0&sig=000000

Teď byste měli mít dvě adresy URL pracovního postupu:

//Success Request Url
https://prodxxx.eastus.logic.azure.com:443/workflows/000000/triggers/manual/paths/invoke?api-version=2016-10-01&sp=%2Ftriggers%2Fmanual%2Frun&sv=1.0&sig=000000

//Fail Request Url
https://prodxxx.eastus.logic.azure.com:443/workflows/000000/triggers/manual/paths/invoke?api-version=2016-10-01&sp=%2Ftriggers%2Fmanual%2Frun&sv=1.0&sig=000000

Vytvoření datové továrny

Spusťte webový prohlížeč Microsoft Edge nebo Google Chrome. Uživatelské rozhraní služby Data Factory podporují v současnosti jenom webové prohlížeče Microsoft Edge a Google Chrome.
Rozbalte nabídku vlevo nahoře a vyberte Vytvořit prostředek. Pak vyberte Analytics>Data Factory :
Na stránce Nová datová továrna jako název zadejte ADFTutorialDataFactory.

Název objektu pro vytváření dat Azure musí být globálně jedinečný. Pokud se zobrazí následující chyba, změňte název objektu pro vytváření dat (třeba na váš_název_ADFTutorialDataFactory) a zkuste to znovu. Pravidla pojmenování artefaktů služby Data Factory najdete v článku Data Factory – pravidla pojmenování.

Název datové továrny ADFTutorialDataFactory není k dispozici.
Vyberte své předplatné Azure, ve kterém chcete vytvořit datovou továrnu.
Pro Skupinu prostředků proveďte jeden z následujících postupů:
- Vyberte Použít existující a z rozevíracího seznamu vyberte existující skupinu prostředků.
- Vyberte Vytvořit novou a zadejte název skupiny prostředků.
  
  Informace o skupinách prostředků najdete v článku Použití skupin prostředků ke správě prostředků Azure.
Jako verzi vyberte V2.
Vyberte umístění pro datovou továrnu. V rozevíracím seznamu jsou zobrazena pouze podporovaná místa. Úložiště dat (Azure Storage, Azure SQL Database atd.) a výpočetní prostředí (HDInsight atd.) používané datovou továrnou mohou být v jiných oblastech.
Zaškrtněte Připnout na řídicí panel.
Klikněte na Vytvořit.
Po vytvoření se zobrazí stránka Datová továrna, jak je znázorněno na obrázku.
Klikněte na dlaždici Otevřít Azure Data Factory Studio pro spuštění uživatelského rozhraní Azure Data Factory na samostatné kartě.

Vytvořit kanál

V tomto kroku vytvoříte kanál s jednou aktivitou kopírování a dvěma aktivitami webu. K vytvoření pipeliny použijete následující funkci:

Parametry pro datový kanál, k nimž přistupují datové sady.
Webová aktivita, která vyvolá pracovní postupy aplikace logiky pro odeslání e-mailů informujících o úspěchu nebo selhání.
Připojení jedné aktivity k jiné aktivitě (v případ úspěchu a selhání)
Použití výstupu aktivity jako vstupu pro další aktivitu

Na domovské stránce uživatelského rozhraní služby Data Factory klikněte na dlaždici Orchestrate .
V okně Vlastnosti datového toku přepněte na kartu Parametry a pomocí tlačítka Nový přidejte následující tři parametry typu Řetězec: sourceBlobContainer, sinkBlobContainer a receiver.
- sourceBlobContainer – parameter potrubí, který je využíván zdrojovou datovou sadou typu blob.
- sinkBlobContainer – parametr v potrubí spotřebovaném datovou sadou pro objekt blob jímky
- receiver – tento parametr se používá ve dvou webových aktivitách v potrubí, které posílají e-maily o úspěchu nebo selhání příjemci, jehož e-mailová adresa je určena tímto parametrem.
V panelu Aktivity vyhledejte Kopírovat a přetáhněte aktivitu Kopírovat na plochu návrháře kanálu.
Vyberte aktivitu kopírování, kterou jste přetáhli na plochu návrháře kanálu. V okně Vlastnosti aktivity Kopírování přepněte v dolní části na kartu Zdroj a klikněte na + Nový. V tomto kroku vytvoříte zdrojovou datovou sadu pro aktivitu kopírování.
V okně Nová datová sada vyberte v horní části kartu Azure a pak zvolte Azure Blob Storage a pak vyberte Pokračovat.
V okně Vybrat formát vyberte Oddělený text a zvolte Pokračovat.
Zobrazí se nová karta s názvem Nastavit vlastnosti. Změňte název datové sady na SourceBlobDataset. Vyberte rozevírací seznam Propojená služba a zvolte +Nový a vytvořte novou propojenou službu se zdrojovou datovou sadou.

Zobrazuje snímek obrazovky okna "Nastavit vlastnosti" datové sady, se zvýrazněným tlačítkem "+Nový" pod rozbalovacím seznamem "Propojená služba".
Zobrazí se okno Nová propojená služba , kde můžete vyplnit požadované vlastnosti propojené služby.
V okně Nová propojená služba proveďte následující kroky:
1. Jako Název zadejte AzureStorageLinkedService.
2. Jako Název účtu úložiště vyberte svůj účet úložiště Azure.
3. Klikněte na Vytvořit.
V okně Nastavit vlastnosti, které se zobrazí dále, vyberte Otevřít tuto datovou sadu a zadejte parametrizovanou hodnotu názvu souboru.
Jako složku zadejte @pipeline().parameters.sourceBlobContainer a jako název souboru zadejte emp.txt.
Přepněte zpět na kartu pipeline (nebo klikněte na pipeline ve stromovém zobrazení vlevo) a vyberte kopírovací aktivitu v návrhářském prostředí. Ověřte, že je pro zdrojovou datovou sadu vybraná nová datová sada.
V okně Vlastnosti přepněte na kartu Jímka a klikněte na + Nová v části Datová sada jímky. V tomto kroku pro aktivitu kopírování vytvoříte cílovou datovou sadu stejně jako jste vytvořili zdrojovou datovou sadu.
V okně Nová datová sada vyberte Azure Blob Storage a klikněte na Pokračovat, poté v okně Vybrat formát opět vyberte Text s oddělovači a znovu klikněte na Pokračovat.
Na stránce Nastavit vlastnosti datové sady zadejte SinkBlobDataset pro Název a vyberte AzureStorageLinkedService pro LinkedService.
Rozbalte část Upřesnit na stránce vlastností a vyberte Otevřít tuto datovou sadu.
Na kartě Připojení datové sady upravte cestu k souboru. Zadejte @pipeline().parameters.sinkBlobContainer složku a @concat(pipeline().RunId, '.txt') název souboru. Tento výraz používá ID aktuálního spuštění pipeline jako název souboru. Seznam podporovaných systémových proměnných a výrazů najdete v tématech Systémové proměnné a Jazyk výrazů.
Přepněte zpět na záložku Pipeline v horní části. Vyhledejte Web ve vyhledávacím poli a přetáhněte aktivitu Web na plochu návrháře pipeline. Nastavte název aktivity na SendSuccessEmailActivity. Aktivita webu umožňuje volání libovolného koncového bodu REST. Další informace o této aktivitě najdete v tématu věnovaném aktivitě webu. Tento datový tok používá webovou aktivitu k volání pracovního postupu emailů v Logic Apps.
Z karty Obecné přepněte na kartu Nastavení a proveďte následující kroky:
1. Jako Adresa URL zadejte adresu URL pracovního postupu aplikace logiky, který odešle e-mail informující o úspěchu.
2. Jako Metoda vyberte POST.
3. V části Záhlaví klikněte na odkaz + Přidat záhlaví.
4. Přidejte záhlaví Content-Type a nastavte ho na hodnotu application/json.
5. Zadejte následující JSON pro tělo.
```
{
    "message": "@{activity('Copy1').output.dataWritten}",
    "dataFactoryName": "@{pipeline().DataFactory}",
    "pipelineName": "@{pipeline().Pipeline}",
    "receiver": "@pipeline().parameters.receiver"
}
```
  Text zprávy obsahuje následující vlastnosti:
  - Zpráva - Předávání hodnoty @{activity('Copy1').output.dataWritten. Přistupuje k vlastnosti předchozí aktivity kopírování a předává hodnotu zapsaných dat. V případě neúspěchu předejte výstup chyby místo @{activity('CopyBlobtoBlob').error.message.
  - Název Data Factory – Předání hodnoty @{pipeline().DataFactory} Toto je systémová proměnná, která vám umožňuje přístup k názvu odpovídající datové továrny. Seznam systémových proměnných najdete v článku Systémové proměnné.
  - Název potrubí – Předání hodnoty @{pipeline().Pipeline}. Toto je také systémová proměnná, která umožňuje přístup k názvu odpovídajícího kanálu.
  - Receiver – Předání hodnoty "@pipeline().parameters.receiver". Přístup k parametrům pipeliny.
Připojte aktivitu kopírování k webové aktivitě přetažením zeleného tlačítka zaškrtávacího políčka vedle aktivita Copy a přetažením na webovou aktivitu.
Přetáhněte další aktivitu Web z panelu nástrojů Aktivity na plochu návrháře kanálu a nastavte její název na SendFailureEmailActivity.
Přepněte na kartu Nastavení a proveďte následující kroky:
1. Jako Adresa URL zadejte adresu URL pracovního postupu aplikace logiky, který odešle e-mail informující o selhání.
2. Jako Metoda vyberte POST.
3. V části Záhlaví klikněte na odkaz + Přidat záhlaví.
4. Přidejte záhlaví Content-Type a nastavte ho na hodnotu application/json.
5. Zadejte následující JSON pro tělo.
```
{
    "message": "@{activity('Copy1').error.message}",
    "dataFactoryName": "@{pipeline().DataFactory}",
    "pipelineName": "@{pipeline().Pipeline}",
    "receiver": "@pipeline().parameters.receiver"
}
```
Vyberte červené tlačítko X na pravé straně aktivity Kopírování v návrháři pipeline a přetáhněte ho na aktivitu SendFailureEmailActivity, kterou jste právě vytvořili.
Pokud chcete kanál ověřit, klikněte na tlačítko Ověřit na panelu nástrojů. Zavřete okno Výstup ověření kanálu kliknutím na tlačítko >>.
Pokud chcete publikovat entity (datové sady, kanály atd.) do služby Data Factory, vyberte Publikovat vše. Počkejte, dokud se nezobrazí zpráva Publikování proběhlo úspěšně.

Aktivace spuštění kanálu, které proběhne úspěšně

Pokud chcete aktivovat spuštění kanálu, klikněte na Spustit na panelu nástrojů a potom klikněte na Spustit nyní.
V okně Spuštění sestavy proveďte následující kroky:
1. Jako hodnotu parametru sourceBlobContainer zadejte adftutorial/adfv2branch/input.
2. Jako hodnotu parametru sinkBlobContainer zadejte adftutorial/adfv2branch/output.
3. Zadejte e-mailovou adresupříjemce.
4. Klikněte na Dokončit.

Sledujte úspěšné spuštění potrubí

Pokud chcete monitorovat spuštění datového toku, přepněte na kartu Monitor na levé straně. Zobrazí se spuštění procesu, které jste spustili ručně. Pomocí tlačítka Aktualizovat seznam aktualizujte.
Pokud chcete zobrazit spuštění aktivit související se spuštěním této datové linky, klikněte na první odkaz ve sloupci Akce. Zpět na předchozí zobrazení můžete přepnout kliknutím na Kanály v horní části. Pomocí tlačítka Aktualizovat seznam aktualizujte.

Spusťte proces potrubí, který selže

Vlevo přepněte na kartu Upravit.
Pokud chcete aktivovat spuštění kanálu, klikněte na Spustit na panelu nástrojů a potom klikněte na Spustit nyní.
V okně Spuštění sestavy proveďte následující kroky:
1. Jako hodnotu parametru sourceBlobContainer zadejte adftutorial/dummy/input. Ujistěte se, že v kontejneru adftutorial neexistuje složka dummy.
2. Jako hodnotu parametru sinkBlobContainer zadejte adftutorial/dummy/output.
3. Zadejte e-mailovou adresupříjemce.
4. Klikněte na Finish (Dokončit).

Sledujte neúspěšné spuštění kanálu

Pokud chcete monitorovat spuštění datového toku, přepněte na kartu Monitor na levé straně. Zobrazí se spuštění procesu, které jste spustili ručně. Pomocí tlačítka Aktualizovat seznam aktualizujte.
Klikněte na odkaz Chyba pro běh kanálu a zobrazte podrobnosti o chybě.
Pokud chcete zobrazit spuštění aktivit související se spuštěním této datové linky, klikněte na první odkaz ve sloupci Akce. Pomocí tlačítka Aktualizovat seznam aktualizujte. Všimněte si, že aktivita kopírování v pipeline selhala. Aktivita webu úspěšně odeslala zadanému příjemci e-mail informující o chybě.
Kliknutím na odkaz Chyba ve sloupci Akce zobrazte podrobnosti o chybě.