Tworzenie wyzwalacza uruchamiającego potok według harmonogramu

DOTYCZY: Azure Data Factory Azure Synapse Analytics

Ten artykuł zawiera informacje o wyzwalaczu harmonogramu oraz krokach tworzenia, uruchamiania i monitorowania wyzwalacza harmonogramu. Aby uzyskać informacje o innych typach wyzwalaczy, zobacz Wykonywanie i wyzwalacze potoku.

Podczas tworzenia wyzwalacza harmonogramu należy określić harmonogram (datę rozpoczęcia, cykl, datę zakończenia itp.) dla wyzwalacza i skojarzyć go z potokiem. Między potokami i wyzwalaczami występuje relacja wiele-do-wielu. Wiele wyzwalaczy może uruchomić jeden potok. Jeden wyzwalacz może uruchamiać wiele potoków.

W poniższych sekcjach przedstawiono kroki tworzenia wyzwalacza harmonogramu na różne sposoby.

Środowisko portalu usługi Azure Data Factory i usługi Synapse

Możesz utworzyć wyzwalacz harmonogramu, aby zaplanować okresowe uruchamianie potoku (co godzinę, codziennie itp.).

1. Przejdź do karty Edycja w usłudze Data Factory lub na karcie Integracja w usłudze Azure Synapse.

   • Azure Data Factory
   • Azure Synapse

   

2. Wybierz pozycję Wyzwalacz w menu, a następnie wybierz pozycję Nowy/Edytuj.

   

3. Na stronie Dodawanie wyzwalaczy wybierz pozycję Wybierz wyzwalacz..., a następnie wybierz pozycję +Nowy.

   

4. Na stronie Nowy wyzwalacz wykonaj następujące czynności:

   1. Upewnij się, że dla opcji Typ wybrano opcję Harmonogram.

   2. Określ datę rozpoczęcia wyzwalacza dla daty rozpoczęcia. Jest ona domyślnie ustawiona na bieżącą datę/godzinę w uniwersalnym czasie koordynowanym (UTC).

   3. Określ strefę czasową, w której zostanie utworzony wyzwalacz. Ustawienie strefy czasowej będzie miało zastosowanie do opcji Data rozpoczęcia, Data zakończenia i Czas wykonywania harmonogramu w opcjach zaawansowanego cyklu. Zmiana ustawienia Strefy czasowej nie spowoduje automatycznej zmiany daty rozpoczęcia. Upewnij się, że data rozpoczęcia jest poprawna w określonej strefie czasowej. Należy pamiętać, że zaplanowany czas wykonania wyzwalacza zostanie uznany za po dacie rozpoczęcia (upewnij się, że data rozpoczęcia jest co najmniej 1 minuta mniejsza niż czas wykonania, w przeciwnym razie potok zostanie wyzwolony w następnym cyklu).

      Uwaga

      W przypadku stref czasowych, które obserwują oszczędność światła dziennego, czas wyzwalacza automatycznie dostosuje się do zmiany dwa razy w roku, jeśli cykl jest ustawiony na dni lub powyżej. Aby zrezygnować ze zmiany czasu letniego, wybierz strefę czasową, która nie obserwuje oszczędzania światła dziennego, na przykład UTC

      Ważne

      Zmiana czasu letniego odbywa się tylko w przypadku wyzwalacza z cyklem ustawionym na dni lub powyżej. Jeśli wyzwalacz ma ustawioną częstotliwość Godziny lub Minuty , będzie on nadal uruchamiany w regularnych odstępach czasu.

   4. Określ cykl dla wyzwalacza. Wybierz jedną z wartości z listy rozwijanej (co minuta, co minuta, co godzinę, codziennie, co tydzień i co miesiąc). Wprowadź mnożnik w polu tekstowym. Jeśli na przykład chcesz, aby wyzwalacz był uruchamiany raz na 15 minut, wybierz pozycję Co minutę i wprowadź wartość 15 w polu tekstowym.

   5. Jeśli z listy rozwijanej wybierzesz pozycję "Dni, Tygodnie lub Miesiące", możesz znaleźć pozycję "Zaawansowane opcje cyklu".

   6. Aby określić datę zakończenia, wybierz pozycję Określ datę zakończenia, a następnie wybierz przycisk OK. Z każdym uruchomieniem potoku wiąże się koszt. Jeśli testujesz, możesz upewnić się, że potok jest wyzwalany tylko kilka razy. Upewnij się również, że okres między czasem publikowania i czasem zakończenia będzie wystarczający do uruchomienia potoku. Wyzwalacz wchodzi w życie dopiero po opublikowaniu rozwiązania, a nie podczas zapisywania wyzwalacza w interfejsie użytkownika.

      

      

5. W oknie Nowy wyzwalacz wybierz pozycję Tak w opcji Aktywowano, a następnie wybierz przycisk OK. To pole wyboru umożliwia późniejsze dezaktywowanie wyzwalacza.

   

6. W oknie Nowy wyzwalacz przejrzyj komunikat ostrzegawczy, a następnie wybierz przycisk OK.

   

7. Wybierz pozycję Opublikuj wszystko , aby opublikować zmiany. Dopóki nie opublikujesz zmian, wyzwalacz nie rozpocznie wyzwalania przebiegów potoku.

   

8. Przejdź do karty Uruchomienia potoku po lewej stronie, a następnie wybierz pozycję Odśwież, aby odświeżyć listę. Zostaną wyświetlone uruchomienia potoków wyzwalane przez zaplanowany wyzwalacz. Zwróć uwagę na wartości w kolumnie Wyzwolone przez. Jeśli używasz opcji Wyzwól teraz , na liście zostanie wyświetlony wyzwalacz ręczny.

   • Azure Data Factory
   • Azure Synapse

   

9. Przejdź do widoku Harmonogram przebiegów \ wyzwalaczy.

   • Azure Data Factory
   • Azure Synapse

   

Azure PowerShell

W tej sekcji pokazano, jak używać programu Azure PowerShell do tworzenia, uruchamiania i monitorowania wyzwalacza harmonogramu. Aby zobaczyć, jak działa ten przykład, najpierw zapoznaj się z przewodnikiem Szybki start: tworzenie fabryki danych przy użyciu programu Azure PowerShell. Następnie dodaj następujący kod do metody main, która tworzy i uruchamia wyzwalacz harmonogramu uruchamiany co 15 minut. Wyzwalacz jest skojarzony z potokiem o nazwie Adfv2QuickStartPipeline utworzonym w ramach przewodnika Szybki start.

Wymagania wstępne

• Subskrypcja platformy Azure. Jeśli nie masz subskrypcji platformy Azure, przed rozpoczęciem utwórz bezpłatne konto.

• Azure PowerShell. Postępuj zgodnie z instrukcjami w temacie Instalowanie programu Azure PowerShell w systemie Windows przy użyciu modułu PowerShellGet.

Przykładowy kod

1. Utwórz plik JSON o nazwie MyTrigger.json w folderze C:\ADFv2QuickStartPSH\ o następującej zawartości:

   Ważne

   Przed zapisaniem pliku JSON ustaw wartość elementu startTime na bieżącą godzinę UTC. Ustaw wartość elementu endTime na jedną godzinę po bieżącej godzinie UTC.

   {
       "properties": {
           "name": "MyTrigger",
           "type": "ScheduleTrigger",
           "typeProperties": {
               "recurrence": {
                   "frequency": "Minute",
                   "interval": 15,
                   "startTime": "2017-12-08T00:00:00Z",
                   "endTime": "2017-12-08T01:00:00Z",
                   "timeZone": "UTC"
               }
           },
           "pipelines": [{
                   "pipelineReference": {
                       "type": "PipelineReference",
                       "referenceName": "Adfv2QuickStartPipeline"
                   },
                   "parameters": {
                       "inputPath": "adftutorial/input",
                       "outputPath": "adftutorial/output"
                   }
               }
           ]
       }
   }
   

   We fragmencie kodu JSON:

   • Element type wyzwalacza jest ustawiony na wartość "ScheduleTrigger".

   • Element frequency jest ustawiony na wartość "Minute", a element interval jest ustawiony na 15. W związku z tym wyzwalacz uruchamia potok co 15 minut między godzinami rozpoczęcia i zakończenia.

   • Element timeZone określa strefę czasową, w której jest tworzony wyzwalacz. To ustawienie ma wpływ zarówno na startTime, jak i endTime.

   • Element endTime jest jedną godzinę po wartości elementu startTime . W związku z tym wyzwalacz uruchamia potok 15 minut, 30 minut i 45 minut po godzinie rozpoczęcia. Nie zapomnij zaktualizować godziny rozpoczęcia do bieżącej godziny UTC, a godzina zakończenia do godziny ostatniej godziny rozpoczęcia.

     Ważne

     W przypadku strefy czasowej UTC czas startTime i endTime muszą być zgodne z formatem "rrrr-MM-ddTHH:mm:ssZ", podczas gdy w przypadku innych stref czasowych, startTime i endTime należy postępować zgodnie z instrukcjami "rrrr-MM-ddTHH:mm:ss".

     Zgodnie ze standardem ISO 8601 sufiks Z oznacza znacznik czasu daty/godziny do strefy czasowej UTC i renderuje pole timeZone bezużyteczne. Brak sufiksu Z dla strefy czasowej UTC spowoduje błąd po aktywacji wyzwalacza.

   • Wyzwalacz jest skojarzony z potokiem Adfv2QuickStartPipeline . Aby skojarzyć wiele potoków z wyzwalaczem, dodaj więcej sekcji pipelineReference .

   • Potok w przewodniku Szybki start przyjmuje dwie wartości parametrów: inputPath i outputPath. I przekazujesz wartości tych parametrów z wyzwalacza.

2. Utwórz wyzwalacz przy użyciu polecenia cmdlet Set-AzDataFactoryV2Trigger :

   Set-AzDataFactoryV2Trigger -ResourceGroupName $ResourceGroupName -DataFactoryName $DataFactoryName -Name "MyTrigger" -DefinitionFile "C:\ADFv2QuickStartPSH\MyTrigger.json"
   

3. Upewnij się, że stan wyzwalacza jest zatrzymany przy użyciu polecenia cmdlet Get-AzDataFactoryV2Trigger :

   Get-AzDataFactoryV2Trigger -ResourceGroupName $ResourceGroupName -DataFactoryName $DataFactoryName -Name "MyTrigger"
   

4. Uruchom wyzwalacz przy użyciu polecenia cmdlet Start-AzDataFactoryV2Trigger :

   Start-AzDataFactoryV2Trigger -ResourceGroupName $ResourceGroupName -DataFactoryName $DataFactoryName -Name "MyTrigger"
   

5. Upewnij się, że stan wyzwalacza to Rozpoczęto przy użyciu polecenia cmdlet Get-AzDataFactoryV2Trigger :

   Get-AzDataFactoryV2Trigger -ResourceGroupName $ResourceGroupName -DataFactoryName $DataFactoryName -Name "MyTrigger"
   

6. Pobierz przebiegi wyzwalacza w programie Azure PowerShell przy użyciu polecenia cmdlet Get-AzDataFactoryV2TriggerRun . Aby uzyskać informacje o uruchomieniach wyzwalacza, wykonaj następujące polecenie okresowo. Zaktualizuj wartości TriggerRunStartedAfter i TriggerRunStartedBefore, aby odpowiadały wartościom w definicji wyzwalacza:

   Get-AzDataFactoryV2TriggerRun -ResourceGroupName $ResourceGroupName -DataFactoryName $DataFactoryName -TriggerName "MyTrigger" -TriggerRunStartedAfter "2017-12-08T00:00:00" -TriggerRunStartedBefore "2017-12-08T01:00:00"
   

   Uwaga

   Czas wyzwalacza harmonogramu jest określony w znaczniku czasu UTC. TriggerRunStartedAfter i TriggerRunStartedBefore oczekuje również znacznika czasu UTC

   Aby monitorować uruchomienia wyzwalacza i uruchomienia potoków w witrynie Azure Portal, zobacz Monitorowanie przebiegów potoków.

Interfejs wiersza polecenia platformy Azure

W tej sekcji pokazano, jak używać interfejsu wiersza polecenia platformy Azure do tworzenia, uruchamiania i monitorowania wyzwalacza harmonogramu. Aby zobaczyć, jak działa ten przykład, najpierw zapoznaj się z przewodnikiem Szybki start: tworzenie usługi Azure Data Factory przy użyciu interfejsu wiersza polecenia platformy Azure. Następnie wykonaj poniższe kroki, aby utworzyć i uruchomić wyzwalacz harmonogramu uruchamiany co 15 minut. Wyzwalacz jest skojarzony z potokiem o nazwie Adfv2QuickStartPipeline utworzonym w ramach przewodnika Szybki start.

Wymagania wstępne

• Użyj środowiska powłoki Bash w usłudze Azure Cloud Shell. Aby uzyskać więcej informacji, zobacz Szybki start dotyczący powłoki Bash w usłudze Azure Cloud Shell.

  

• Jeśli wolisz uruchamiać polecenia referencyjne interfejsu wiersza polecenia lokalnie, zainstaluj interfejs wiersza polecenia platformy Azure. Jeśli korzystasz z systemu Windows lub macOS, rozważ uruchomienie interfejsu wiersza polecenia platformy Azure w kontenerze Docker. Aby uzyskać więcej informacji, zobacz Jak uruchomić interfejs wiersza polecenia platformy Azure w kontenerze platformy Docker.

  • Jeśli korzystasz z instalacji lokalnej, zaloguj się do interfejsu wiersza polecenia platformy Azure za pomocą polecenia az login. Aby ukończyć proces uwierzytelniania, wykonaj kroki wyświetlane w terminalu. Aby uzyskać inne opcje logowania, zobacz Logowanie się przy użyciu interfejsu wiersza polecenia platformy Azure.

  • Po wyświetleniu monitu zainstaluj rozszerzenie interfejsu wiersza polecenia platformy Azure podczas pierwszego użycia. Aby uzyskać więcej informacji na temat rozszerzeń, zobacz Korzystanie z rozszerzeń w interfejsie wiersza polecenia platformy Azure.

  • Uruchom polecenie az version, aby znaleźć zainstalowane wersje i biblioteki zależne. Aby uaktualnić do najnowszej wersji, uruchom polecenie az upgrade.

Przykładowy kod

1. W katalogu roboczym utwórz plik JSON o nazwie MyTrigger.json z właściwościami wyzwalacza. W tym przykładzie użyj następującej zawartości:

   Ważne

   Przed zapisaniem pliku JSON ustaw wartość elementu startTime na bieżącą godzinę UTC. Ustaw wartość elementu endTime na jedną godzinę po bieżącej godzinie UTC.

   {
       "name": "MyTrigger",
       "type": "ScheduleTrigger",
       "typeProperties": {
           "recurrence": {
               "frequency": "Minute",
               "interval": 15,
               "startTime": "2017-12-08T00:00:00Z",
               "endTime": "2017-12-08T01:00:00Z",
               "timeZone": "UTC"
           }
       },
       "pipelines": [{
               "pipelineReference": {
                   "type": "PipelineReference",
                   "referenceName": "Adfv2QuickStartPipeline"
               },
               "parameters": {
                   "inputPath": "adftutorial/input",
                   "outputPath": "adftutorial/output"
               }
           }
       ]
   }
   

   We fragmencie kodu JSON:

   • Element type wyzwalacza jest ustawiony na wartość "ScheduleTrigger".

   • Element frequency jest ustawiony na wartość "Minute", a element interval jest ustawiony na 15. W związku z tym wyzwalacz uruchamia potok co 15 minut między godzinami rozpoczęcia i zakończenia.

   • Element timeZone określa strefę czasową, w której jest tworzony wyzwalacz. To ustawienie ma wpływ zarówno na startTime, jak i endTime.

   • Element endTime jest jedną godzinę po wartości elementu startTime . W związku z tym wyzwalacz uruchamia potok 15 minut, 30 minut i 45 minut po godzinie rozpoczęcia. Nie zapomnij zaktualizować godziny rozpoczęcia do bieżącej godziny UTC, a godzina zakończenia do godziny ostatniej godziny rozpoczęcia.

     Ważne

     W przypadku strefy czasowej UTC czas startTime i endTime muszą być zgodne z formatem "rrrr-MM-ddTHH:mm:ssZ", podczas gdy w przypadku innych stref czasowych, startTime i endTime należy postępować zgodnie z instrukcjami "rrrr-MM-ddTHH:mm:ss".

     Zgodnie ze standardem ISO 8601 sufiks Z oznacza znacznik czasu daty/godziny do strefy czasowej UTC i renderuje pole timeZone bezużyteczne. Brak sufiksu Z dla strefy czasowej UTC spowoduje błąd po aktywacji wyzwalacza.

   • Wyzwalacz jest skojarzony z potokiem Adfv2QuickStartPipeline . Aby skojarzyć wiele potoków z wyzwalaczem, dodaj więcej sekcji pipelineReference .

   • Potok w przewodniku Szybki start przyjmuje dwie wartości parametrów: inputPath i outputPath. I przekazujesz wartości tych parametrów z wyzwalacza.

2. Utwórz wyzwalacz za pomocą polecenia az datafactory trigger create :

   az datafactory trigger create --resource-group "ADFQuickStartRG" --factory-name "ADFTutorialFactory"  --name "MyTrigger" --properties @MyTrigger.json  
   

3. Upewnij się, że stan wyzwalacza jest zatrzymany przy użyciu polecenia az datafactory trigger show :

   az datafactory trigger show --resource-group "ADFQuickStartRG" --factory-name "ADFTutorialFactory" --name "MyTrigger" 
   

4. Uruchom wyzwalacz za pomocą polecenia az datafactory trigger start :

   az datafactory trigger start --resource-group "ADFQuickStartRG" --factory-name "ADFTutorialFactory" --name "MyTrigger" 
   

5. Upewnij się, że stan wyzwalacza to Uruchomiono przy użyciu polecenia az datafactory trigger show :

   az datafactory trigger show --resource-group "ADFQuickStartRG" --factory-name "ADFTutorialFactory" --name "MyTrigger" 
   

6. Pobierz przebiegi wyzwalacza w interfejsie wiersza polecenia platformy Azure przy użyciu polecenia az datafactory trigger-run query-by-factory . Aby uzyskać informacje na temat przebiegów wyzwalacza, wykonaj następujące polecenie okresowo. Zaktualizuj wartości last-update-after i last-updated-before, aby były zgodne z wartościami w definicji wyzwalacza:

   az datafactory trigger-run query-by-factory --resource-group "ADFQuickStartRG" --factory-name "ADFTutorialFactory" --filters operand="TriggerName" operator="Equals" values="MyTrigger" --last-updated-after "2017-12-08T00:00:00" --last-updated-before "2017-12-08T01:00:00"
   

   Uwaga

   Czas wyzwalacza harmonogramu jest określony w znaczniku czasu UTC. last-updated-after i last-updated-before również oczekuje znacznika czasu UTC

   Aby monitorować uruchomienia wyzwalacza i uruchomienia potoków w witrynie Azure Portal, zobacz Monitorowanie przebiegów potoków.

Zestaw SDK platformy .NET

W tej sekcji pokazano, jak używać zestawu SDK platformy .NET do tworzenia, uruchamiania i monitorowania wyzwalacza. Aby zobaczyć, jak działa ten przykład, najpierw zapoznaj się z przewodnikiem Szybki start: tworzenie fabryki danych przy użyciu zestawu .NET SDK. Następnie dodaj następujący kod do metody main, która tworzy i uruchamia wyzwalacz harmonogramu uruchamiany co 15 minut. Wyzwalacz jest skojarzony z potokiem o nazwie Adfv2QuickStartPipeline utworzonym w ramach przewodnika Szybki start.

Aby utworzyć i uruchomić wyzwalacz harmonogramu uruchamiany co 15 minut, dodaj następujący kod do metody main:

            // Create the trigger
            Console.WriteLine("Creating the trigger");

            // Set the start time to the current UTC time
            DateTime startTime = DateTime.UtcNow;

            // Specify values for the inputPath and outputPath parameters
            Dictionary<string, object> pipelineParameters = new Dictionary<string, object>();
            pipelineParameters.Add("inputPath", "adftutorial/input");
            pipelineParameters.Add("outputPath", "adftutorial/output");

            // Create a schedule trigger
            string triggerName = "MyTrigger";
            ScheduleTrigger myTrigger = new ScheduleTrigger()
            {
                Pipelines = new List<TriggerPipelineReference>()
                {
                    // Associate the Adfv2QuickStartPipeline pipeline with the trigger
                    new TriggerPipelineReference()
                    {
                        PipelineReference = new PipelineReference(pipelineName),
                        Parameters = pipelineParameters,
                    }
                },
                Recurrence = new ScheduleTriggerRecurrence()
                {
                    // Set the start time to the current UTC time and the end time to one hour after the start time
                    StartTime = startTime,
                    TimeZone = "UTC",
                    EndTime = startTime.AddHours(1),
                    Frequency = RecurrenceFrequency.Minute,
                    Interval = 15,
                }
            };

            // Now, create the trigger by invoking the CreateOrUpdate method
            TriggerResource triggerResource = new TriggerResource()
            {
                Properties = myTrigger
            };
            client.Triggers.CreateOrUpdate(resourceGroup, dataFactoryName, triggerName, triggerResource);

            // Start the trigger
            Console.WriteLine("Starting the trigger");
            client.Triggers.Start(resourceGroup, dataFactoryName, triggerName);

Aby utworzyć wyzwalacze w innej strefie czasowej, inne niż UTC, wymagane są następujące ustawienia:

<<ClientInstance>>.SerializationSettings.DateFormatHandling = Newtonsoft.Json.DateFormatHandling.IsoDateFormat;
<<ClientInstance>>.SerializationSettings.DateTimeZoneHandling = Newtonsoft.Json.DateTimeZoneHandling.Unspecified;
<<ClientInstance>>.SerializationSettings.DateParseHandling = DateParseHandling.None;
<<ClientInstance>>.DeserializationSettings.DateParseHandling = DateParseHandling.None;
<<ClientInstance>>.DeserializationSettings.DateFormatHandling = Newtonsoft.Json.DateFormatHandling.IsoDateFormat;
<<ClientInstance>>.DeserializationSettings.DateTimeZoneHandling = Newtonsoft.Json.DateTimeZoneHandling.Unspecified;

Aby monitorować przebieg wyzwalacza, dodaj następujący kod przed ostatnią Console.WriteLine instrukcją w przykładzie:

            // Check that the trigger runs every 15 minutes
            Console.WriteLine("Trigger runs. You see the output every 15 minutes");

            for (int i = 0; i < 3; i++)
            {
                System.Threading.Thread.Sleep(TimeSpan.FromMinutes(15));
                List<TriggerRun> triggerRuns = client.Triggers.ListRuns(resourceGroup, dataFactoryName, triggerName, DateTime.UtcNow.AddMinutes(-15 * (i + 1)), DateTime.UtcNow.AddMinutes(2)).ToList();
                Console.WriteLine("{0} trigger runs found", triggerRuns.Count);

                foreach (TriggerRun run in triggerRuns)
                {
                    foreach (KeyValuePair<string, string> triggeredPipeline in run.TriggeredPipelines)
                    {
                        PipelineRun triggeredPipelineRun = client.PipelineRuns.Get(resourceGroup, dataFactoryName, triggeredPipeline.Value);
                        Console.WriteLine("Pipeline run ID: {0}, Status: {1}", triggeredPipelineRun.RunId, triggeredPipelineRun.Status);
                        List<ActivityRun> runs = client.ActivityRuns.ListByPipelineRun(resourceGroup, dataFactoryName, triggeredPipelineRun.RunId, run.TriggerRunTimestamp.Value, run.TriggerRunTimestamp.Value.AddMinutes(20)).ToList();
                    }
                }
            }

Aby monitorować uruchomienia wyzwalacza i uruchomienia potoków w witrynie Azure Portal, zobacz Monitorowanie przebiegów potoków.

Zestaw SDK dla języka Python

W tej sekcji pokazano, jak używać zestawu SDK języka Python do tworzenia, uruchamiania i monitorowania wyzwalacza. Aby zobaczyć, jak działa ten przykład, najpierw zapoznaj się z przewodnikiem Szybki start: tworzenie fabryki danych przy użyciu zestawu SDK języka Python. Następnie dodaj następujący blok kodu po bloku kodu "monitorowanie uruchomienia potoku" w skrypsie języka Python. Ten kod tworzy wyzwalacz harmonogramu uruchamiany co 15 minut między określonymi godzinami rozpoczęcia i zakończenia. Zaktualizuj zmienną start_time do bieżącej godziny UTC, a zmienna end_time na jedną godzinę po bieżącej godzinie UTC.

    # Create a trigger
    tr_name = 'mytrigger'
    scheduler_recurrence = ScheduleTriggerRecurrence(frequency='Minute', interval='15',start_time='2017-12-12T04:00:00Z', end_time='2017-12-12T05:00:00Z', time_zone='UTC')
    pipeline_parameters = {'inputPath':'adftutorial/input', 'outputPath':'adftutorial/output'}
    pipelines_to_run = []
    pipeline_reference = PipelineReference('copyPipeline')
    pipelines_to_run.append(TriggerPipelineReference(pipeline_reference, pipeline_parameters))
    tr_properties = TriggerResource(properties=ScheduleTrigger(description='My scheduler trigger', pipelines = pipelines_to_run, recurrence=scheduler_recurrence))
    adf_client.triggers.create_or_update(rg_name, df_name, tr_name, tr_properties)

    # Start the trigger
    adf_client.triggers.start(rg_name, df_name, tr_name)

Aby monitorować uruchomienia wyzwalacza i uruchomienia potoków w witrynie Azure Portal, zobacz Monitorowanie przebiegów potoków.

Szablon usługi Azure Resource Manager

Aby utworzyć wyzwalacz, możesz użyć szablonu usługi Azure Resource Manager. Aby uzyskać instrukcje krok po kroku, zobacz Tworzenie fabryki danych Azure przy użyciu szablonu usługi Resource Manager.

Przekazywanie czasu rozpoczęcia wyzwalacza do potoku

Usługa Azure Data Factory w wersji 1 obsługuje odczytywanie lub zapisywanie partycjonowanych danych przy użyciu zmiennych systemowych: SliceStart, SliceEnd, WindowStart i WindowEnd. W bieżącej wersji potoków usług Azure Data Factory i Synapse można osiągnąć to zachowanie przy użyciu parametru potoku. Czas rozpoczęcia i zaplanowany czas wyzwalacza są ustawiane jako wartość parametru potoku. W poniższym przykładzie zaplanowany czas wyzwalacza jest przekazywany jako wartość do parametru scheduledRunTime potoku:

"parameters": {
    "scheduledRunTime": "@trigger().scheduledTime"
}

Schemat systemu JSON

Poniższa definicja JSON pokazuje, jak utworzyć wyzwalacz harmonogramu z planowaniem i cyklem:

{
  "properties": {
    "type": "ScheduleTrigger",
    "typeProperties": {
      "recurrence": {
        "frequency": <<Minute, Hour, Day, Week, Month>>,
        "interval": <<int>>,             // Optional, specifies how often to fire (default to 1)
        "startTime": <<datetime>>,
        "endTime": <<datetime - optional>>,
        "timeZone": "UTC"
        "schedule": {                    // Optional (advanced scheduling specifics)
          "hours": [<<0-23>>],
          "weekDays": [<<Monday-Sunday>>],
          "minutes": [<<0-59>>],
          "monthDays": [<<1-31>>],
          "monthlyOccurrences": [
               {
                    "day": <<Monday-Sunday>>,
                    "occurrence": <<1-5>>
               }
           ]
        }
      }
    },
   "pipelines": [
            {
                "pipelineReference": {
                    "type": "PipelineReference",
                    "referenceName": "<Name of your pipeline>"
                },
                "parameters": {
                    "<parameter 1 Name>": {
                        "type": "Expression",
                        "value": "<parameter 1 Value>"
                    },
                    "<parameter 2 Name>" : "<parameter 2 Value>"
                }
           }
      ]
  }
}

Przegląd schematu

Poniższa tabela zawiera ogólne omówienie głównych elementów schematu odnoszących się do powtarzania i planowania wyzwalacza:

Wartości domyślne, limity i przykłady harmonogramów

Opcja strefy czasowej

Poniżej przedstawiono niektóre strefy czasowe obsługiwane dla wyzwalaczy harmonogramu:

Ta lista jest niekompletna. Aby uzyskać pełną listę opcji strefy czasowej, zapoznaj się ze stroną tworzenia wyzwalacza portalu

Właściwość startTime

W poniższej tabeli przedstawiono, w jaki sposób właściwość startTime kontroluje uruchamianie wyzwalacza:

Zobaczmy przykład zdarzeń w przypadku, gdy czas rozpoczęcia przypada w przeszłości, z cyklem, ale bez harmonogramu. Załóżmy, że obecna data i godzina to 2017-04-08 13:00, czas rozpoczęcia to 2017-04-07 14:00, a cykl jest określony na 2 dni. (Wartość cyklu jest definiowana przez ustawienie właściwości frequency na "day" i właściwość interval na 2. Zwróć uwagę, że wartość startTime jest w przeszłości i występuje przed bieżącą godziną.

W tych warunkach pierwsze wykonanie znajduje się pod adresem 2017-04-0914:00. Aparat harmonogramu oblicza wystąpienia wykonania od czasu rozpoczęcia. Wszystkie wystąpienia w przeszłości są odrzucane. Aparat wykorzystuje następne wystąpienie, które ma miejsce w przyszłości. W tym scenariuszu czas rozpoczęcia wynosi , więc następne wystąpienie wynosi 2017-04-072:00pmdwa dni od tego czasu, czyli 2017-04-09 o 2:00pmwartości .

Czas pierwszego wykonania jest identyczny, nawet jeśli właściwość startTime ma wartość 2017-04-05 14:00 lub 2017-04-01 14:00. Po pierwszym wykonaniu kolejne wykonania są obliczane przy użyciu harmonogramu. W związku z tym kolejne wykonania znajdują się w 2:00pm2017-04-11 godzinie , a następnie 2017-04-13 w 2:00pm2:00pm, i 2017-04-15 tak dalej.

Gdy z kolei w harmonogramie wyzwalacza nie ustawiono godzin lub minut, wartością domyślną będą godziny lub minuty pierwszego wykonania.

Wartość schedule

Użycie harmonogramu może ograniczyć liczbę wykonań wyzwalacza. Jeśli na przykład uruchomienie wyzwalacza z częstotliwością miesięczną zaplanowano na 31. dzień, wyzwalacz będzie uruchamiany tylko w miesiącach, której mają 31 dni.

Harmonogram może także zwiększyć liczbę wykonań wyzwalacza. Na przykład wyzwalacz z częstotliwością miesięczną, którego uruchomienie zaplanowano na 1. i 2. dzień miesiąca, będzie uruchamiany 1. i 2. dnia miesiąca, a nie raz na miesiąc.

W przypadku określenia wielu elementów właściwości schedule ocena następuje od największego do najmniejszego elementu. Ocena jest wykonywana w następującej kolejności: numer tygodnia, dzień miesiąca, dzień tygodnia, godzina i minuta.

W poniższej tabeli opisano szczegółowo elementy właściwości schedule:

Przykłady harmonogramów cyklu wyzwalaczy

Ta sekcja zawiera przykłady harmonogramów cyklu i koncentruje się na obiekcie właściwości schedule oraz jego elementach.

W przykładach założono, ze wartość właściwości interval wynosi 1 oraz że wartość właściwości frequency jest prawidłowa i zgodna z definicją harmonogramu. Na przykład nie można mieć właściwości frequency o wartości „day” i jednocześnie modyfikacji „monthDays” w obiekcie schedule. Tego typu ograniczenia są wymienione w tabeli w poprzedniej sekcji.

Powiązana zawartość

• Aby uzyskać szczegółowe informacje o wyzwalaczach, zobacz Wykonywanie i wyzwalacze potoku.
• Dowiedz się, jak odwoływać się do metadanych wyzwalacza w potoku, zobacz Reference Trigger Metadata in Pipeline Runs (Odwołania do metadanych wyzwalacza w uruchomieniach potoku)