PublishedPipeline Kelas

Mewakili Alur yang akan dikirimkan tanpa kode Python yang membangunnya.

Selain itu, PublishedPipeline dapat digunakan untuk mengirim ulang dengan nilai dan input yang Pipeline berbeda PipelineParameter .

Inisialisasi PublishedPipeline.

:p titik akhir URL titik akhir REST untuk mengirimkan eksekusi alur untuk alur ini. :type endpoint: str :p aram total_run_steps: Jumlah langkah dalam alur ini :type total_run_steps: int :p aram workspace: Ruang kerja alur yang diterbitkan. :type workspace: azureml.core.Workspace :p aram continue_on_step_failure: Apakah akan melanjutkan eksekusi langkah lain di PipelineRun

jika langkah gagal, defaultnya adalah false.

Konstruktor

PublishedPipeline(name, graph_id, description, version, published_pipeline_id, status, endpoint, total_run_steps, workspace, continue_on_step_failure=None, _pipeline_provider=None, **kwargs)

Parameter

Nama	Deskripsi
name Diperlukan	str Nama alur yang diterbitkan.
graph_id Diperlukan	str ID grafik untuk alur yang diterbitkan ini.
description Diperlukan	str Deskripsi alur yang diterbitkan.
version Diperlukan	str Versi alur yang diterbitkan.
published_pipeline_id Diperlukan	str ID alur yang diterbitkan.
status Diperlukan	str Status alur yang diterbitkan ('Aktif' atau 'Dinonaktifkan').
endpoint Diperlukan	str URL titik akhir REST untuk mengirimkan eksekusi untuk alur ini.
total_run_steps Diperlukan	int Jumlah langkah dalam alur ini.
workspace Diperlukan	Workspace Ruang kerja alur yang diterbitkan.
continue_on_step_failure Diperlukan	bool Apakah akan melanjutkan eksekusi langkah lain di PipelineRun jika langkah gagal. Defaultnya adalah false.
_pipeline_provider Diperlukan	<xref:azureml.pipeline.core._workflow_provider._PublishedPipelineProvider> Penyedia alur yang diterbitkan.
kwargs Diperlukan	dict Argumen kata kunci kustom, dicadangkan untuk pengembangan di masa mendatang
name Diperlukan	str Nama alur yang diterbitkan.
graph_id Diperlukan	str ID grafik untuk alur yang diterbitkan ini.
description Diperlukan	str Deskripsi alur yang diterbitkan.
version Diperlukan	str Versi alur yang diterbitkan.
published_pipeline_id Diperlukan	str ID alur yang diterbitkan.
status Diperlukan	str Status alur yang diterbitkan ('Aktif' atau 'Dinonaktifkan').
_pipeline_provider Diperlukan	<xref:azureml.pipeline.core._workflow_provider._PublishedPipelineProvider> Penyedia alur yang diterbitkan.
kwargs Diperlukan	dict Argumen kata kunci kustom, dicadangkan untuk pengembangan di masa mendatang

Keterangan

PublishedPipeline dapat dibuat dari Pipeline atau PipelineRun.

Contoh untuk menerbitkan dari Alur adalah sebagai berikut:


   from azureml.pipeline.core import Pipeline

   pipeline = Pipeline(workspace=ws, steps=steps)
   published_pipeline = pipeline.publish(name="My_New_Pipeline",
                                         description="My New Pipeline Description",
                                         version="1.0",
                                         continue_on_step_failure=True)

Untuk menerbitkan dari PipelineRun gunakan:


   from azureml.pipeline.core import PipelineRun

   pipeline_run = PipelineRun(experiment=Experiment(ws, "Pipeline_experiment"), run_id="run_id")
   published_pipeline = pipeline_run.publish_pipeline(name="My_New_Pipeline",
                                                      description="My New Pipeline Description",
                                                      version="1.0",
                                                      continue_on_step_failure=True)

Catatan: parameter continue_on_step_failure menentukan apakah eksekusi langkah-langkah dalam Alur akan dilanjutkan jika satu langkah gagal. Nilai defaultnya adalah False, yang berarti ketika satu langkah gagal, eksekusi Alur akan berhenti, membatalkan langkah yang sedang berjalan.

Kirim PublishedPipeline menggunakan submit. Saat pengiriman dipanggil, dibuat PipelineRun yang pada gilirannya membuat StepRun objek untuk setiap langkah dalam alur kerja.

Contoh untuk mengirimkan PublishedPipeline adalah sebagai berikut:


   from azureml.pipeline.core import PublishedPipeline

   published_pipeline = PublishedPipeline.get(workspace=ws, id="published_pipeline_id")
   pipeline_run = experiment.submit(published_pipeline)

Ada sejumlah pengaturan opsional yang dapat ditentukan saat mengirimkan PublishedPipeline. Ini termasuk:

continue_on_step_failure: Apakah akan melanjutkan eksekusi langkah lain di PipelineRun jika langkah gagal, opsional. Hanya langkah-langkah yang tidak memiliki dependensi pada output langkah yang gagal yang akan melanjutkan eksekusi. Jika disediakan, pengaturan parameter ini akan mengambil alih pengaturan pada Alur.
pipeline_parameters: Parameter untuk eksekusi alur, kamus {name: value}. Lihat PipelineParameter untuk detail selengkapnya.
parent_run_id: Anda dapat menyediakan ID eksekusi untuk mengatur eksekusi induk eksekusi alur ini, yang tercermin dalam RunHistory. Eksekusi induk harus milik eksperimen yang sama dengan alur yang dikirimkan.

Contoh untuk mengirimkan PublishedPipeline menggunakan pengaturan ini adalah sebagai berikut:


   from azureml.pipeline.core import PublishedPipeline

   published_pipeline = PublishedPipeline.get(workspace=ws, id="published_pipeline_id")
   pipeline_run = experiment.submit(published_pipeline,
                                    continue_on_step_failure=True,
                                    pipeline_parameters={"param1": "value1"},
                                    parent_run_id="<run_id>")

Semua alur yang diterbitkan memiliki titik akhir REST. Dengan titik akhir alur, Anda dapat memicu eksekusi alur dari sistem eksternal, seperti klien non-Python. Untuk informasi tentang cara mengautentikasi saat memanggil titik akhir REST, lihat https://aka.ms/pl-restep-auth.

Menggunakan titik akhir memungkinkan "pengulangan terkelola" dalam skenario penilaian dan pelatihan ulang batch, misalnya. Untuk informasi selengkapnya, lihat https://aka.ms/pl-first-pipeline .

Metode

disable	Atur alur yang diterbitkan ke 'Dinonaktifkan' dan tidak tersedia untuk dijalankan.
enable	Atur alur yang diterbitkan ke 'Aktif' dan tersedia untuk dijalankan.
get	Dapatkan alur yang diterbitkan.
get_all	Dapatkan semua alur yang diterbitkan di ruang kerja saat ini. TIDAK DIGUNAKAN LAGI: Metode ini tidak digunakan lagi demi metode PublishedPipeline list .
get_graph	Dapatkan grafik PublishedPipeline.
get_step_names	Dapatkan daftar nama langkah-langkah di PublishedPipeline.
list	Dapatkan semua alur yang diterbitkan di ruang kerja saat ini.
save	Simpan YAML Alur ke file. Saat ini, hanya alur yang terdiri dari ModuleSteps yang didukung untuk ekspor YAML.
submit	Kirim alur yang diterbitkan. Ini setara dengan menggunakan submit. Mengembalikan yang dikirimkan PipelineRun. Gunakan objek ini untuk memantau dan melihat detail eksekusi.

disable

Atur alur yang diterbitkan ke 'Dinonaktifkan' dan tidak tersedia untuk dijalankan.

disable()

enable

Atur alur yang diterbitkan ke 'Aktif' dan tersedia untuk dijalankan.

enable()

get

Dapatkan alur yang diterbitkan.

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

Parameter

Nama	Deskripsi
workspace Diperlukan	Workspace Ruang kerja tempat alur yang diterbitkan dibuat.
id Diperlukan	str ID alur yang diterbitkan.
_workflow_provider	<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider> Penyedia alur kerja. Nilai default: None
_service_endpoint	str Titik akhir layanan. Nilai default: None

Mengembalikan

Jenis	Deskripsi
PublishedPipeline	Objek PublishedPipeline.

get_all

Dapatkan semua alur yang diterbitkan di ruang kerja saat ini.

TIDAK DIGUNAKAN LAGI: Metode ini tidak digunakan lagi demi metode PublishedPipeline list .

static get_all(workspace, active_only=True, _service_endpoint=None)

Parameter

Nama	Deskripsi
workspace Diperlukan	Workspace Ruang kerja tempat alur yang diterbitkan dibuat.
active_only	bool Apakah hanya mengembalikan alur yang diterbitkan yang saat ini aktif. Nilai default: True
_service_endpoint	str Titik akhir layanan. Nilai default: None

Mengembalikan

Jenis	Deskripsi
list[PublishedPipeline]	Daftar objek PublishedPipeline.

get_graph

Dapatkan grafik PublishedPipeline.

get_graph(_workflow_provider=None)

Parameter

Nama	Deskripsi
_workflow_provider	<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider> Penyedia alur kerja. Nilai default: None

Mengembalikan

Jenis	Deskripsi
Graph	Grafiknya.

get_step_names

Dapatkan daftar nama langkah-langkah di PublishedPipeline.

get_step_names(_workflow_provider=None)

Parameter

Nama	Deskripsi
_workflow_provider	<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider> Penyedia alur kerja. Nilai default: None

Mengembalikan

Jenis	Deskripsi
List[str]	Daftar nama langkah-langkah di PublishedPipeline.

list

Dapatkan semua alur yang diterbitkan di ruang kerja saat ini.

static list(workspace, active_only=True, _service_endpoint=None)

Parameter

Nama	Deskripsi
workspace Diperlukan	Workspace Ruang kerja tempat alur yang diterbitkan dibuat.
active_only	bool Apakah hanya mengembalikan alur yang diterbitkan yang saat ini aktif. Nilai default: True
_service_endpoint	str Titik akhir layanan. Nilai default: None

Mengembalikan

Jenis	Deskripsi
list[PublishedPipeline]	Daftar objek PublishedPipeline.

save

Simpan YAML Alur ke file.

Saat ini, hanya alur yang terdiri dari ModuleSteps yang didukung untuk ekspor YAML.

save(path=None, _workflow_provider=None)

Parameter

Nama	Deskripsi
path	str Jalur untuk menyimpan YAML. Jika jalur adalah direktori, file YAML Alur disimpan di jalur/pipeline_name.yml. Jika jalur tidak ada, direktori saat ini digunakan. Nilai default: None
_workflow_provider	<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider> Penyedia alur kerja. Nilai default: None

Mengembalikan

Jenis	Deskripsi
None

submit

Kirim alur yang diterbitkan. Ini setara dengan menggunakan submit.

Mengembalikan yang dikirimkan PipelineRun. Gunakan objek ini untuk memantau dan melihat detail eksekusi.

submit(workspace, experiment_name, pipeline_parameters=None, _workflow_provider=None, _service_endpoint=None, parent_run_id=None, continue_on_step_failure=None)

Parameter

Nama	Deskripsi
workspace Diperlukan	Workspace Ruang kerja untuk mengirimkan alur yang diterbitkan.
experiment_name Diperlukan	str Nama eksperimen yang akan dikirimkan.
pipeline_parameters	dict Kamus parameter untuk menetapkan nilai baru {nama param, nilai param}. Lihat PipelineParameter untuk detail selengkapnya. Nilai default: None
_workflow_provider	<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider> Penyedia alur kerja. Nilai default: None
_service_endpoint	str Titik akhir layanan. Nilai default: None
parent_run_id	str ID eksekusi opsional untuk diatur untuk eksekusi induk eksekusi alur ini, yang tercermin dalam RunHistory. Eksekusi induk harus milik eksperimen yang sama dengan alur ini sedang dikirimkan. Nilai default: None
continue_on_step_failure	bool Apakah akan melanjutkan eksekusi langkah lain di PipelineRun jika langkah gagal, opsional. Jika disediakan, akan mengambil alih pengaturan pada Alur. Nilai default: None

Mengembalikan

Jenis	Deskripsi
PipelineRun	Eksekusi alur yang dikirimkan.

Atribut

continue_on_step_failure

Dapatkan nilai continue_on_step_failure pengaturan.

Mengembalikan

Jenis	Deskripsi
bool	Nilai `continue_on_step_failure` pengaturan.

description

Dapatkan deskripsi alur yang diterbitkan.

Mengembalikan

Jenis	Deskripsi
str	Deskripsi alur yang diterbitkan.

endpoint

Dapatkan URL titik akhir REST untuk menjalankan alur yang diterbitkan.

Mengembalikan

Jenis	Deskripsi
str	URL titik akhir REST untuk menjalankan alur yang diterbitkan.

graph_id

Dapatkan ID grafik untuk alur yang diterbitkan ini.

Mengembalikan

Jenis	Deskripsi
str	ID grafik.

id

Dapatkan ID alur yang diterbitkan.

Mengembalikan

Jenis	Deskripsi
str	ID alur yang diterbitkan.

name

Dapatkan nama alur yang diterbitkan.

Mengembalikan

Jenis	Deskripsi
str	Nama alur yang diterbitkan.

status

Dapatkan status alur yang diterbitkan.

Mengembalikan

Jenis	Deskripsi
str	Status alur yang diterbitkan.

total_run_steps

Dapatkan jumlah langkah dalam alur.

Mengembalikan

Jenis	Deskripsi
int	Jumlah langkah dalam alur.

version

Dapatkan versi alur yang diterbitkan.

Mengembalikan

Jenis	Deskripsi
str	Versi alur yang diterbitkan.

Saran dan Komentar

Apakah halaman ini membantu?

Bagikan melalui

PublishedPipeline Kelas

Konstruktor

Parameter

Keterangan

Metode

disable

enable

get

Parameter

Mengembalikan

get_all

Parameter

Mengembalikan

get_graph

Parameter

Mengembalikan

get_step_names

Parameter

Mengembalikan

list

Parameter

Mengembalikan

save

Parameter

Mengembalikan

submit

Parameter

Mengembalikan

Atribut

continue_on_step_failure

Mengembalikan

description

Mengembalikan

endpoint

Mengembalikan

graph_id

Mengembalikan

id

Mengembalikan

name

Mengembalikan

status

Mengembalikan

total_run_steps

Mengembalikan

version

Mengembalikan

Saran dan Komentar