Schedule Klasa

Odwołanie

Definiuje harmonogram przesyłania potoku.

Po opublikowaniu potoku harmonogram może służyć do przesyłania potoku w określonym interwale lub w przypadku wykrycia zmian w lokalizacji magazynu obiektów blob.

Zainicjuj harmonogram.

Dziedziczenie: builtins.object

Schedule

Konstruktor

Schedule(workspace, id, name, description, pipeline_id, status, recurrence, datastore_name, polling_interval, data_path_parameter_name, continue_on_step_failure, path_on_datastore, _schedule_provider=None, pipeline_endpoint_id=None)

Parametry

Nazwa	Opis
workspace Wymagane	Workspace Obiekt obszaru roboczego, do którego będzie należeć ten harmonogram.
id Wymagane	str Identyfikator harmonogramu.
name Wymagane	str Nazwa harmonogramu.
description Wymagane	str Opis harmonogramu.
pipeline_id Wymagane	str Identyfikator potoku, który zostanie przesłany.
status Wymagane	str Stan harmonogramu, "Aktywny" lub "Wyłączony".
recurrence Wymagane	ScheduleRecurrence Cykl harmonogramu dla potoku.
datastore_name Wymagane	str Nazwa magazynu danych do monitorowania zmodyfikowanych/dodanych obiektów blob. Uwaga: 1) Magazyny danych sieci wirtualnej nie są obsługiwane. 2) Typ uwierzytelniania magazynu danych powinien być ustawiony na "Klucz konta".
polling_interval Wymagane	int Jak długo, w minutach, między sondowaniem zmodyfikowanych/dodanych obiektów blob.
data_path_parameter_name Wymagane	str Nazwa parametru potoku ścieżki danych do ustawienia ze zmienioną ścieżką obiektu blob.
continue_on_step_failure Wymagane	bool Czy kontynuować wykonywanie innych kroków w przesłanym potokuRun, jeśli krok zakończy się niepowodzeniem. Jeśli zostanie podana wartość, spowoduje to zastąpienie ustawienia continue_on_step_failure dla potoku.
path_on_datastore Wymagane	str Opcjonalny. Ścieżka w magazynie danych do monitorowania zmodyfikowanych/dodanych obiektów blob. Uwaga: path_on_datastore będzie znajdować się w kontenerze magazynu danych, więc rzeczywista ścieżka, którą będzie monitorować harmonogram, będzie kontener/path_on_datastore. Jeśli nie, kontener magazynu danych jest monitorowany. Dodatki/modyfikacje wprowadzone w podfolderze path_on_datastore nie są monitorowane. Obsługiwane tylko w przypadku harmonogramów magazynu danych.
_schedule_provider	<xref:azureml.pipeline.core._aeva_provider._AevaScheduleProvider> Dostawca harmonogramu. Domyślna wartość: None
workspace Wymagane	Workspace Obiekt obszaru roboczego, do którego będzie należeć ten harmonogram.
id Wymagane	str Identyfikator harmonogramu.
name Wymagane	str Nazwa harmonogramu.
description Wymagane	str Opis harmonogramu.
pipeline_id Wymagane	str Identyfikator potoku, który zostanie przesłany.
status Wymagane	str Stan harmonogramu, "Aktywny" lub "Wyłączony".
recurrence Wymagane	ScheduleRecurrence Cykl harmonogramu potoku.
datastore_name Wymagane	str Nazwa magazynu danych do monitorowania zmodyfikowanych/dodanych obiektów blob. Uwaga: magazyny danych sieci wirtualnej nie są obsługiwane.
polling_interval Wymagane	int Jak długo, w minutach, między sondowaniem zmodyfikowanych/dodanych obiektów blob.
data_path_parameter_name Wymagane	str Nazwa parametru potoku ścieżki danych do ustawienia ze zmienioną ścieżką obiektu blob.
continue_on_step_failure Wymagane	bool Czy kontynuować wykonywanie innych kroków w przesłanym potokuRun, jeśli krok zakończy się niepowodzeniem. Jeśli zostanie podana wartość, spowoduje to zastąpienie ustawienia continue_on_step_failure dla potoku.
path_on_datastore Wymagane	str Opcjonalny. Ścieżka w magazynie danych do monitorowania zmodyfikowanych/dodanych obiektów blob. Uwaga: path_on_datastore będzie znajdować się w kontenerze magazynu danych, więc rzeczywista ścieżka, którą będzie monitorować harmonogram, będzie kontener/path_on_datastore. Jeśli nie, kontener magazynu danych jest monitorowany. Dodatki/modyfikacje wprowadzone w podfolderze path_on_datastore nie są monitorowane. Obsługiwane tylko w przypadku harmonogramów magazynu danych.
_schedule_provider Wymagane	<xref:azureml.pipeline.core._aeva_provider._AevaScheduleProvider> Dostawca harmonogramu.
pipeline_endpoint_id	str Identyfikator punktu końcowego potoku, który zostanie przesłany. Domyślna wartość: None

Uwagi

Obsługiwane są dwa typy harmonogramów. Pierwszy używa cyklu czasu do przesłania potoku zgodnie z danym harmonogramem. Drugi monitoruje AzureBlobDatastore obiekt dla dodanych lub zmodyfikowanych obiektów blob i przesyła potok po wykryciu zmian.

Aby utworzyć harmonogram, który będzie przesyłać potok zgodnie z harmonogramem cyklicznym, użyj elementu ScheduleRecurrence podczas tworzenia harmonogramu.

Funkcja ScheduleRecurrence jest używana podczas tworzenia harmonogramu dla potoku w następujący sposób:


   from azureml.pipeline.core import Schedule, ScheduleRecurrence

   recurrence = ScheduleRecurrence(frequency="Hour", interval=12)
   schedule = Schedule.create(workspace, name="TestSchedule", pipeline_id="pipeline_id",
                              experiment_name="helloworld", recurrence=recurrence)

Ten harmonogram będzie przesyłany co PublishedPipeline 12 godzin. Przesłany potok zostanie utworzony w obszarze Eksperyment o nazwie "helloworld".

Aby utworzyć harmonogram, który spowoduje wyzwolenie elementu PipelineRuns w przypadku modyfikacji lokalizacji magazynu obiektów blob, określ magazyn danych i powiązane informacje o danych podczas tworzenia harmonogramu.


   from azureml.pipeline.core import Schedule
   from azureml.core.datastore import Datastore

   datastore = Datastore(workspace=ws, name="workspaceblobstore")

   schedule = Schedule.create(workspace, name="TestSchedule", pipeline_id="pipeline_id"
                              experiment_name="helloworld", datastore=datastore,
                              polling_interval=5, path_on_datastore="file/path")

Należy pamiętać, że parametry polling_interval i path_on_datastore są opcjonalne. Polling_interval określa, jak często sondować pod kątem modyfikacji magazynu danych, a domyślnie jest to 5 minut. path_on_datastore można użyć do określenia folderu w magazynie danych, który ma być monitorowany pod kątem zmian. Jeśli brak, kontener magazynu danych jest monitorowany. Uwaga: dodatki/modyfikacje obiektów blob w podfolderach path_on_datastore lub kontenera magazynu danych (jeśli nie określono path_on_datastore) nie zostaną wykryte.

Ponadto, jeśli potok został skonstruowany w celu DataPath PipelineParameter opisania danych wejściowych kroku, użyj parametru data_path_parameter_name podczas tworzenia harmonogramu wyzwalanego przez magazyn danych, aby ustawić dane wejściowe na zmieniony plik po przesłaniu potoku zgodnie z harmonogramem.

W poniższym przykładzie, gdy harmonogram wyzwoli element PipelineRun, wartość parametru PipelineParameter "input_data" zostanie ustawiona jako plik, który został zmodyfikowany/dodany:


   from azureml.pipeline.core import Schedule
   from azureml.core.datastore import Datastore

   datastore = Datastore(workspace=ws, name="workspaceblobstore")

   schedule = Schedule.create(workspace, name="TestSchedule", pipeline_id="pipeline_id",
                              experiment_name="helloworld", datastore=datastore,
                              data_path_parameter_name="input_data")

Aby uzyskać więcej informacji na temat harmonogramów, zobacz: https://aka.ms/pl-schedule.

Metody

create	Utwórz harmonogram dla potoku. Określ cykl dla harmonogramu opartego na czasie lub określ magazyn danych, (opcjonalnie) polling_interval i (opcjonalnie) data_path_parameter_name, aby utworzyć harmonogram, który będzie monitorować lokalizację magazynu danych pod kątem modyfikacji/dodawania.
create_for_pipeline_endpoint	Utwórz harmonogram dla punktu końcowego potoku. Określ cykl dla harmonogramu opartego na czasie lub określ magazyn danych, (opcjonalnie) polling_interval i (opcjonalnie) data_path_parameter_name, aby utworzyć harmonogram, który będzie monitorować lokalizację magazynu danych pod kątem modyfikacji/dodawania.
disable	Ustaw harmonogram na wartość "Wyłączone" i jest niedostępny do uruchomienia.
enable	Ustaw harmonogram na "Aktywny" i dostępny do uruchomienia.
get	Pobierz harmonogram z danym identyfikatorem.
get_all	Pobierz wszystkie harmonogramy w bieżącym obszarze roboczym. PRZESTARZAŁE: Ta metoda jest przestarzała na rzecz list metody .
get_last_pipeline_run	Pobierz ostatnie uruchomienie potoku przesłane zgodnie z harmonogramem. Zwraca wartość Brak, jeśli nie przesłano żadnych przebiegów.
get_pipeline_runs	Pobierz uruchomienia potoku wygenerowane na podstawie harmonogramu.
get_schedules_for_pipeline_endpoint_id	Pobierz wszystkie harmonogramy dla danego identyfikatora punktu końcowego potoku.
get_schedules_for_pipeline_id	Pobierz wszystkie harmonogramy dla danego identyfikatora potoku.
list	Pobierz wszystkie harmonogramy w bieżącym obszarze roboczym.
load_yaml	Załaduj i odczytaj plik YAML, aby uzyskać parametry harmonogramu. Plik YAML to jeszcze jeden sposób przekazywania parametrów harmonogramu w celu utworzenia harmonogramu.
update	Zaktualizuj harmonogram.

create

Utwórz harmonogram dla potoku.

Określ cykl dla harmonogramu opartego na czasie lub określ magazyn danych, (opcjonalnie) polling_interval i (opcjonalnie) data_path_parameter_name, aby utworzyć harmonogram, który będzie monitorować lokalizację magazynu danych pod kątem modyfikacji/dodawania.

static create(workspace, name, pipeline_id, experiment_name, recurrence=None, description=None, pipeline_parameters=None, wait_for_provisioning=False, wait_timeout=3600, datastore=None, polling_interval=5, data_path_parameter_name=None, continue_on_step_failure=None, path_on_datastore=None, _workflow_provider=None, _service_endpoint=None)

Parametry

Nazwa	Opis
workspace Wymagane	Workspace Obiekt obszaru roboczego, do którego będzie należeć ten harmonogram.
name Wymagane	str Nazwa harmonogramu.
pipeline_id Wymagane	str Identyfikator potoku, który zostanie przesłany.
experiment_name Wymagane	str Nazwa eksperymentu, na który zostanie przesłany harmonogram.
recurrence	ScheduleRecurrence Cykl harmonogramu potoku. Domyślna wartość: None
description	str Opis harmonogramu. Domyślna wartość: None
pipeline_parameters	dict Słownik parametrów do przypisywania nowych wartości {param name, param value} Domyślna wartość: None
wait_for_provisioning	bool Czy poczekać na ukończenie aprowizacji harmonogramu. Domyślna wartość: False
wait_timeout	int Liczba sekund oczekiwania przed upływem limitu czasu. Domyślna wartość: 3600
datastore	AzureBlobDatastore Magazyn danych do monitorowania zmodyfikowanych/dodanych obiektów blob. Uwaga: magazyny danych sieci wirtualnej nie są obsługiwane. Nie można używać z cyklem. Domyślna wartość: None
polling_interval	int Jak długo, w minutach, między sondowaniem zmodyfikowanych/dodanych obiektów blob. Wartość domyślna to 5 minut. Obsługiwane tylko w przypadku harmonogramów magazynu danych. Domyślna wartość: 5
data_path_parameter_name	str Nazwa parametru potoku ścieżki danych do ustawienia ze zmienioną ścieżką obiektu blob. Obsługiwane tylko w przypadku harmonogramów magazynu danych. Domyślna wartość: None
continue_on_step_failure	bool Czy kontynuować wykonywanie innych kroków w przesłanym potokuRun, jeśli krok zakończy się niepowodzeniem. Jeśli zostanie podana wartość, spowoduje to zastąpienie ustawienia continue_on_step_failure dla potoku. Domyślna wartość: None
path_on_datastore	str Opcjonalny. Ścieżka w magazynie danych do monitorowania zmodyfikowanych/dodanych obiektów blob. Uwaga: path_on_datastore będzie znajdować się w kontenerze dla magazynu danych, więc rzeczywista ścieżka, którą będzie monitorować harmonogram, będzie kontenerem/path_on_datastore. Jeśli nie, kontener magazynu danych jest monitorowany. Dodatki/modyfikacje wprowadzone w podfolderze path_on_datastore nie są monitorowane. Obsługiwane tylko w przypadku harmonogramów magazynu danych. Domyślna wartość: None
_workflow_provider	<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider> Dostawca przepływu pracy. Domyślna wartość: None
_service_endpoint	str Punkt końcowy usługi. Domyślna wartość: None

Zwraca

Typ	Opis
Schedule	Utworzony harmonogram.

create_for_pipeline_endpoint

Utwórz harmonogram dla punktu końcowego potoku.

static create_for_pipeline_endpoint(workspace, name, pipeline_endpoint_id, experiment_name, recurrence=None, description=None, pipeline_parameters=None, wait_for_provisioning=False, wait_timeout=3600, datastore=None, polling_interval=5, data_path_parameter_name=None, continue_on_step_failure=None, path_on_datastore=None, _workflow_provider=None, _service_endpoint=None)

Parametry

Nazwa	Opis
workspace Wymagane	Workspace Obiekt obszaru roboczego, do którego będzie należeć ten harmonogram.
name Wymagane	str Nazwa harmonogramu.
pipeline_endpoint_id Wymagane	str Identyfikator punktu końcowego potoku, który zostanie przesłany.
experiment_name Wymagane	str Nazwa eksperymentu, na który zostanie przesłany harmonogram.
recurrence	ScheduleRecurrence Cykl harmonogramu potoku. Domyślna wartość: None
description	str Opis harmonogramu. Domyślna wartość: None
pipeline_parameters	dict Słownik parametrów do przypisywania nowych wartości {param name, param value} Domyślna wartość: None
wait_for_provisioning	bool Czy poczekać na ukończenie aprowizacji harmonogramu. Domyślna wartość: False
wait_timeout	int Liczba sekund oczekiwania przed przekroczeniem limitu czasu. Domyślna wartość: 3600
datastore	AzureBlobDatastore Magazyn danych do monitorowania pod kątem zmodyfikowanych/dodanych obiektów blob. Uwaga: magazyny danych sieci wirtualnej nie są obsługiwane. Nie można używać z cyklem. Domyślna wartość: None
polling_interval	int Jak długo, w minutach, między sondowaniem pod kątem zmodyfikowanych/dodanych obiektów blob. Wartość domyślna to 5 minut. Obsługiwane tylko w przypadku harmonogramów magazynu danych. Domyślna wartość: 5
data_path_parameter_name	str Nazwa parametru potoku ścieżki danych do ustawienia ze zmienioną ścieżką obiektu blob. Obsługiwane tylko w przypadku harmonogramów magazynu danych. Domyślna wartość: None
continue_on_step_failure	bool Czy kontynuować wykonywanie innych kroków w przesłanym potokuUruchom, jeśli krok zakończy się niepowodzeniem. Jeśli zostanie podana wartość , spowoduje to zastąpienie ustawienia continue_on_step_failure dla potoku. Domyślna wartość: None
path_on_datastore	str Opcjonalny. Ścieżka w magazynie danych do monitorowania zmodyfikowanych/dodanych obiektów blob. Uwaga: path_on_datastore będzie znajdować się w kontenerze dla magazynu danych, więc rzeczywista ścieżka, którą będzie monitorować harmonogram, będzie kontenerem/path_on_datastore. Jeśli nie, kontener magazynu danych jest monitorowany. Dodatki/modyfikacje wprowadzone w podfolderze path_on_datastore nie są monitorowane. Obsługiwane tylko w przypadku harmonogramów magazynu danych. Domyślna wartość: None
_workflow_provider	<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider> Dostawca przepływu pracy. Domyślna wartość: None
_service_endpoint	str Punkt końcowy usługi. Domyślna wartość: None

Zwraca

Typ	Opis
Schedule	Utworzony harmonogram.

disable

Ustaw harmonogram na wartość "Wyłączone" i jest niedostępny do uruchomienia.

disable(wait_for_provisioning=False, wait_timeout=3600)

Parametry

Nazwa	Opis
wait_for_provisioning	bool Czy poczekać na ukończenie aprowizacji harmonogramu. Domyślna wartość: False
wait_timeout	int Liczba sekund oczekiwania przed przekroczeniem limitu czasu. Domyślna wartość: 3600

enable

Ustaw harmonogram na "Aktywny" i dostępny do uruchomienia.

enable(wait_for_provisioning=False, wait_timeout=3600)

Parametry

Nazwa	Opis
wait_for_provisioning	bool Czy poczekać na ukończenie aprowizacji harmonogramu. Domyślna wartość: False
wait_timeout	int Liczba sekund oczekiwania przed przekroczeniem limitu czasu. Domyślna wartość: 3600

get

Pobierz harmonogram z danym identyfikatorem.

static get(workspace, id, _workflow_provider=None, _service_endpoint=None)

Parametry

Nazwa	Opis
workspace Wymagane	Workspace Obszar roboczy, w ramach którego został utworzony harmonogram.
id Wymagane	str Identyfikator harmonogramu.
_workflow_provider	<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider> Dostawca przepływu pracy. Domyślna wartość: None
_service_endpoint	str Punkt końcowy usługi. Domyślna wartość: None

Zwraca

Typ	Opis
Schedule	Obiekt harmonogramu

get_all

Pobierz wszystkie harmonogramy w bieżącym obszarze roboczym.

PRZESTARZAŁE: Ta metoda jest przestarzała na rzecz list metody .

static get_all(workspace, active_only=True, pipeline_id=None, pipeline_endpoint_id=None, _workflow_provider=None, _service_endpoint=None)

Parametry

Nazwa	Opis
workspace Wymagane	Workspace Obszar roboczy.
active_only	bool Jeśli wartość true, zwraca tylko harmonogramy, które są obecnie aktywne. Ma zastosowanie tylko wtedy, gdy nie podano identyfikatora potoku. Domyślna wartość: True
pipeline_id	str Jeśli zostanie podana, zwracaj tylko harmonogramy dla potoku z danym identyfikatorem. Domyślna wartość: None
pipeline_endpoint_id	str Jeśli zostanie podana, zwracaj tylko harmonogramy dla punktu końcowego potoku z danym identyfikatorem. Domyślna wartość: None
_workflow_provider	<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider> Dostawca przepływu pracy. Domyślna wartość: None
_service_endpoint	str Punkt końcowy usługi. Domyślna wartość: None

Zwraca

Typ	Opis
list	Lista .Schedule

get_last_pipeline_run

Pobierz ostatnie uruchomienie potoku przesłane zgodnie z harmonogramem. Zwraca wartość Brak, jeśli nie przesłano żadnych przebiegów.

get_last_pipeline_run()

Zwraca

Typ	Opis
PipelineRun	Ostatnie uruchomienie potoku.

get_pipeline_runs

Pobierz uruchomienia potoku wygenerowane na podstawie harmonogramu.

get_pipeline_runs()

Zwraca

Typ	Opis
list	Lista .PipelineRun

get_schedules_for_pipeline_endpoint_id

Pobierz wszystkie harmonogramy dla danego identyfikatora punktu końcowego potoku.

static get_schedules_for_pipeline_endpoint_id(workspace, pipeline_endpoint_id, _workflow_provider=None, _service_endpoint=None)

Parametry

Nazwa	Opis
workspace Wymagane	Workspace Obszar roboczy.
pipeline_endpoint_id Wymagane	str Identyfikator punktu końcowego potoku.
_workflow_provider	<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider> Dostawca przepływu pracy. Domyślna wartość: None
_service_endpoint	str Punkt końcowy usługi. Domyślna wartość: None

Zwraca

Typ	Opis
list	Lista .Schedule

get_schedules_for_pipeline_id

Pobierz wszystkie harmonogramy dla danego identyfikatora potoku.

static get_schedules_for_pipeline_id(workspace, pipeline_id, _workflow_provider=None, _service_endpoint=None)

Parametry

Nazwa	Opis
workspace Wymagane	Workspace Obszar roboczy.
pipeline_id Wymagane	str Identyfikator potoku.
_workflow_provider	<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider> Dostawca przepływu pracy. Domyślna wartość: None
_service_endpoint	str Punkt końcowy usługi. Domyślna wartość: None

Zwraca

Typ	Opis
list	Lista .Schedule

list

Pobierz wszystkie harmonogramy w bieżącym obszarze roboczym.

static list(workspace, active_only=True, pipeline_id=None, pipeline_endpoint_id=None, _workflow_provider=None, _service_endpoint=None)

Parametry

Nazwa	Opis
workspace Wymagane	Workspace Obszar roboczy.
active_only	bool Jeśli wartość true, zwraca tylko harmonogramy, które są obecnie aktywne. Ma zastosowanie tylko wtedy, gdy nie podano identyfikatora potoku. Domyślna wartość: True
pipeline_id	str Jeśli zostanie podana, zwracaj tylko harmonogramy dla potoku z danym identyfikatorem. Domyślna wartość: None
pipeline_endpoint_id	str Jeśli zostanie podana, zwracaj tylko harmonogramy dla punktu końcowego potoku z danym identyfikatorem. Domyślna wartość: None
_workflow_provider	<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider> Dostawca przepływu pracy. Domyślna wartość: None
_service_endpoint	str Punkt końcowy usługi. Domyślna wartość: None

Zwraca

Typ	Opis
list	Lista .Schedule

load_yaml

Załaduj i odczytaj plik YAML, aby uzyskać parametry harmonogramu.

Plik YAML to jeszcze jeden sposób przekazywania parametrów harmonogramu w celu utworzenia harmonogramu.

static load_yaml(workspace, filename, _workflow_provider=None, _service_endpoint=None)

Parametry

Nazwa	Opis
workspace Wymagane	Workspace Obszar roboczy.
filename Wymagane	str Nazwa pliku YAML z lokalizacją.
_workflow_provider	<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider> Dostawca przepływu pracy. Domyślna wartość: None
_service_endpoint	str Punkt końcowy usługi. Domyślna wartość: None

Zwraca

Typ	Opis
dict	Słownik parametrów Schedule i wartości.

Uwagi

W przypadku harmonogramów obsługiwane są dwa typy YAML. Pierwsze operacje odczytu i ładowania informacji o cyklu dla harmonogramu tworzenia w celu wyzwolenia potoku. Drugi odczytuje i ładuje informacje magazynu danych na potrzeby tworzenia harmonogramu w celu wyzwolenia potoku.

Przykład tworzenia harmonogramu, który będzie przesyłał potok w ramach cyklu w następujący sposób:


   from azureml.pipeline.core import Schedule

   schedule_info = Schedule.load_yaml(workspace=workspace,
                                      filename='./yaml/test_schedule_with_recurrence.yaml')
   schedule = Schedule.create(workspace, name="TestSchedule", pipeline_id="pipeline_id",
                              experiment_name="helloworld", recurrence=schedule_info.get("recurrence"),
                              description=schedule_info.get("description"))

Przykładowy plik YAML test_schedule_with_recurrence.yaml:


   Schedule:
       description: "Test create with recurrence"
       recurrence:
           frequency: Week # Can be "Minute", "Hour", "Day", "Week", or "Month".
           interval: 1 # how often fires
           start_time: 2019-06-07T10:50:00
           time_zone: UTC
           hours:
           - 1
           minutes:
           - 0
           time_of_day: null
           week_days:
           - Friday
       pipeline_parameters: {'a':1}
       wait_for_provisioning: True
       wait_timeout: 3600
       datastore_name: ~
       polling_interval: ~
       data_path_parameter_name: ~
       continue_on_step_failure: None
       path_on_datastore: ~

Przykład tworzenia harmonogramu, który będzie przesyłać potok w magazynie danych w następujący sposób:


   from azureml.pipeline.core import Schedule

   schedule_info = Schedule.load_yaml(workspace=workspace,
                                      filename='./yaml/test_schedule_with_datastore.yaml')
   schedule = Schedule.create(workspace, name="TestSchedule", pipeline_id="pipeline_id",
                              experiment_name="helloworld",datastore=schedule_info.get("datastore_name"),
                              polling_interval=schedule_info.get("polling_interval"),
                              data_path_parameter_name=schedule_info.get("data_path_parameter_name"),
                              continue_on_step_failure=schedule_info.get("continue_on_step_failure"),
                              path_on_datastore=schedule_info.get("path_on_datastore"))

update

Zaktualizuj harmonogram.

update(name=None, description=None, recurrence=None, pipeline_parameters=None, status=None, wait_for_provisioning=False, wait_timeout=3600, datastore=None, polling_interval=None, data_path_parameter_name=None, continue_on_step_failure=None, path_on_datastore=None)

Parametry

Nazwa	Opis
name	str Nowa nazwa harmonogramu. Domyślna wartość: None
recurrence	ScheduleRecurrence Nowy harmonogram cyklu potoku. Domyślna wartość: None
description	str Nowy opis harmonogramu. Domyślna wartość: None
pipeline_parameters	dict Słownik parametrów do przypisywania nowych wartości {param name, param value}. Domyślna wartość: None
status	str Nowy stan harmonogramu: "Aktywne" lub "Wyłączone". Domyślna wartość: None
wait_for_provisioning	bool Czy poczekać na ukończenie aprowizacji harmonogramu. Domyślna wartość: False
wait_timeout	int Liczba sekund oczekiwania przed przekroczeniem limitu czasu. Domyślna wartość: 3600
datastore	AzureBlobDatastore Magazyn danych do monitorowania pod kątem zmodyfikowanych/dodanych obiektów blob. Uwaga: magazyny danych sieci wirtualnej nie są obsługiwane. Domyślna wartość: None
polling_interval	int Jak długo, w minutach, między sondowaniem pod kątem zmodyfikowanych/dodanych obiektów blob. Wartość domyślna to 5 minut. Domyślna wartość: None
data_path_parameter_name	str Nazwa parametru potoku ścieżki danych do ustawienia ze zmienioną ścieżką obiektu blob. Domyślna wartość: None
continue_on_step_failure	bool Czy kontynuować wykonywanie innych kroków w przesłanym potokuUruchom, jeśli krok zakończy się niepowodzeniem. Jeśli zostanie podana wartość , spowoduje to zastąpienie ustawienia continue_on_step_failure dla potoku. Domyślna wartość: None
path_on_datastore	str Opcjonalny. Ścieżka w magazynie danych do monitorowania zmodyfikowanych/dodanych obiektów blob. Uwaga: path_on_datastore będzie znajdować się w kontenerze dla magazynu danych, więc rzeczywista ścieżka, którą będzie monitorować harmonogram, będzie kontenerem/path_on_datastore. Jeśli nie, kontener magazynu danych jest monitorowany. Dodatki/modyfikacje wprowadzone w podfolderze path_on_datastore nie są monitorowane. Obsługiwane tylko w przypadku harmonogramów magazynu danych. Domyślna wartość: None

Atrybuty

continue_on_step_failure

Pobierz wartość continue_on_step_failure ustawienia.

Zwraca

Typ	Opis
bool	Wartość `continue_on_step_failure` ustawienia

data_path_parameter_name

Pobierz nazwę parametru potoku ścieżki danych, który ma zostać ustawiony przy użyciu zmienionej ścieżki obiektu blob.

Zwraca

Typ	Opis
str	Nazwa parametru ścieżki danych.

datastore_name

Pobierz nazwę magazynu danych używanego dla harmonogramu.

Zwraca

Typ	Opis
str	Nazwa magazynu danych.

description

Pobierz opis harmonogramu.

Zwraca

Typ	Opis
str	Opis harmonogramu.

id

Pobierz identyfikator harmonogramu.

Zwraca

Typ	Opis
str	Identyfikator.

name

Pobierz nazwę harmonogramu.

Zwraca

Typ	Opis
str	Nazwa.

path_on_datastore

Pobierz ścieżkę do magazynu danych, który monitoruje harmonogram.

Zwraca

Typ	Opis
str	Ścieżka w magazynie danych.

pipeline_endpoint_id

Pobierz identyfikator punktu końcowego potoku, który przesyła harmonogram.

Zwraca

Typ	Opis
str	Identyfikator.

pipeline_id

Pobierz identyfikator potoku, który przesyła harmonogram.

Zwraca

Typ	Opis
str	Identyfikator.

polling_interval

Uzyskaj czas między sondowaniem zmodyfikowanych/dodanych obiektów blob w ciągu kilku minut.

Zwraca

Typ	Opis
int	Interwał sondowania.

recurrence

Uzyskaj cykl harmonogramu.

Zwraca

Typ	Opis
ScheduleRecurrence	Cykl harmonogramu.

status

Uzyskaj stan harmonogramu.

Zwraca

Typ	Opis
str	Stan harmonogramu.

Udostępnij za pośrednictwem

Schedule Klasa

Konstruktor

Parametry

Uwagi

Metody

create

Parametry

Zwraca

create_for_pipeline_endpoint

Parametry

Zwraca

disable

Parametry

enable

Parametry

get

Parametry

Zwraca

get_all

Parametry

Zwraca

get_last_pipeline_run

Zwraca

get_pipeline_runs

Zwraca

get_schedules_for_pipeline_endpoint_id

Parametry

Zwraca

get_schedules_for_pipeline_id

Parametry

Zwraca

list

Parametry

Zwraca

load_yaml

Parametry

Zwraca

Uwagi

update

Parametry

Atrybuty

continue_on_step_failure

Zwraca

data_path_parameter_name

Zwraca

datastore_name

Zwraca

description

Zwraca

id

Zwraca

name

Zwraca

path_on_datastore

Zwraca

pipeline_endpoint_id

Zwraca

pipeline_id

Zwraca

polling_interval

Zwraca

recurrence

Zwraca

status

Zwraca

Opinia

Dodatkowe zasoby