PublishedPipeline Kelas

Referensi

Mewakili Alur yang akan dikirimkan tanpa kode Python yang membuatnya.

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

Menginisialisasi PublishedPipeline.

:p aram 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-langkah lain di PipelineRun

jika langkah gagal, defaultnya adalah false.

Warisan: azureml.core._portal.HasPipelinePortal

PublishedPipeline

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 dari alur yang diterbitkan.
status Diperlukan	str Status alur yang diterbitkan ('Aktif' atau 'Dinonaktifkan').
endpoint Diperlukan	str URL titik akhir REST guna mengirimkan proses 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 suatu langkah gagal. Defaultnya adalah false (salah).
_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 dari 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 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 berlanjut jika satu langkah gagal. Nilai default adalah False, artinya ketika satu langkah gagal, eksekusi Alur akan berhenti, membatalkan langkah-langkah yang sedang berjalan.

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

Contoh 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. Hal ini termasuk:

continue_on_step_failure: Apakah akan melanjutkan eksekusi langkah lain di PipelineRun jika langkah yang dilakukan 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 memberikan ID eksekusi untuk mengatur eksekusi induk dari eksekusi alur ini, yang tercermin dalam RunHistory. Eksekusi induk harus termasuk dalam eksperimen yang sama dengan alur yang dikirimkan.

Contoh 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 batch dan pelatihan ulang, 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 karena 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. Tindakan ini sama dengan menggunakan submit. Mengembalikan PipelineRun yang diserahkan. 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 dari 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 karena 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 akan menampilkan hanya alur yang diterbitkan yang saat ini aktif saja. 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 dalam 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 akan menampilkan hanya alur yang diterbitkan yang saat ini aktif saja. 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 jalurnya adalah direktori, file YAML Alur disimpan di path/pipeline_name.yml. Jika jalur Tidak Ada, direktori saat ini akan 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. Tindakan ini sama dengan menggunakan submit.

Mengembalikan PipelineRun yang diserahkan. 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 dikirim.
pipeline_parameters	dict Kamus parameter untuk menetapkan nilai baru {param name, param value}. 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 mengatur eksekusi induk dalam eksekusi alur ini, yang tercermin dalam RunHistory. Eksekusi induk harus termasuk dalam eksperimen yang sama dengan alur ini yang sedang dikirimkan. nilai default: None
continue_on_step_failure	bool Apakah akan melanjutkan eksekusi langkah lain di PipelineRun jika langkah yang dilakukan gagal, opsional. Jika disediakan, eksekusi akan mengambil alih pengaturan pada Alur. nilai default: None

Mengembalikan

Jenis	Deskripsi
PipelineRun	Alur yang dikirimkan berjalan.

Atribut

continue_on_step_failure

Dapatkan nilai pengaturan continue_on_step_failure.

Mengembalikan

Jenis	Deskripsi
bool	Nilai pengaturan `continue_on_step_failure`.

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 dari 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.

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

Saran dan Komentar

Sumber Daya Tambahan: