PortDataReference Klasse
Modelliert Daten, die einer Ausgabe einer abgeschlossenen Schrittausführung (StepRun) zugeordnet sind.
Mit einem PortDataReference-Objekt können die Ausgabedaten, die von einem StepRun erzeugt wurden, heruntergeladen werden. Es kann auch als Schritteingabe in einer zukünftigen Pipeline verwendet werden.
Initialisieren Sie PortDataReference.
- Vererbung
-
builtins.objectPortDataReference
Konstruktor
PortDataReference(context, pipeline_run_id, data_reference, step_run=None)
Parameter
Name | Beschreibung |
---|---|
context
Erforderlich
|
<xref:azureml.pipeline.core._GraphContext>
Das Graphkontextobjekt. |
pipeline_run_id
Erforderlich
|
Die ID der Pipelineausführung, die die Ausgabe generiert hat. |
data_reference
Erforderlich
|
Das Datenverweisobjekt. |
step_run
|
Das StepRun-Objekt, das die Daten generiert hat. Standardwert: None
|
context
Erforderlich
|
<xref:azureml.pipeline.core._GraphContext>
Das Graphkontextobjekt. |
pipeline_run_id
Erforderlich
|
Die ID der Pipelineausführung, die die Ausgabe generiert hat. |
data_reference
Erforderlich
|
Das Datenverweisobjekt. |
step_run
Erforderlich
|
Das StepRun-Objekt, das die Daten generiert hat. |
Hinweise
Eine PortDataReference verweist auf Daten, die in einem abgeschlossenen StepRun erstellt wurden.
Ruft eine PortDataReference wie folgt aus einem PipelineRun ab und lädt die Ausgabedaten herunter:
from azureml.pipeline.core import PipelineRun, StepRun, PortDataReference
pipeline_run = PipelineRun(experiment, "<pipeline_run_id>")
step_run = pipeline_run.find_step_run("<node_name>")[0]
port_data_reference = step_run.get_output_data("<output_name>")
port_data_reference.download(local_path="path")
Eine PortDataReference kann als Eingabe für einen Schritt in einer Pipeline verwendet werden, ähnlich wie bei der Verwendung von DataReference.
Das folgende Beispiel zeigt die Verwendung einer PortDataReference als Schritteingabe:
from azureml.pipeline.core import PortDataReference, Pipeline, PipelineRun
from azureml.pipeline.steps import PythonScriptStep
pipeline_run = PipelineRun(experiment, "<pipeline_run_id>")
step_run = pipeline_run.find_step_run("<node_name>")[0]
port_data_reference = step_run.get_output_data("<output_name>")
step_1 = PythonScriptStep(
name='train',
script_name="train.py",
compute_target=compute,
arguments=["--input", port_data_reference],
inputs=[port_data_reference]
)
pipeline = Pipeline(workspace=workspace, steps=[step_1])
In diesem Beispiel verwendet die neu erstellte Pipeline die Ausgabe, die von der abgeschlossenen PipelineRun erstellt wurde, als Eingabe für den Trainingsschritt.
Methoden
as_download |
Verwendet PortDataReference über den Modus „download“ als Schritteingabe. |
as_input |
Erstellt eine InputPortBinding und gibt einen Eingabenamen an (verwendet dabei aber den Standardmodus). |
as_mount |
Verwendet PortDataReference über den Modus „mount“ als Schritteingabe. |
create_input_binding |
Erstellt die Eingabebindung mit dieser PortDataReference als Quelle. |
download |
Lädt die durch PortDataReference dargestellten Daten herunter. |
as_download
Verwendet PortDataReference über den Modus „download“ als Schritteingabe.
as_download(input_name=None, path_on_compute=None, overwrite=None)
Parameter
Name | Beschreibung |
---|---|
input_name
|
Gibt einen Namen für diese Eingabe an. Standardwert: None
|
path_on_compute
|
Der Pfad am Computeziel, in den die Daten heruntergeladen werden sollen. Standardwert: None
|
overwrite
|
Gibt an, ob vorhandene Daten überschrieben werden sollen. Standardwert: None
|
Gibt zurück
Typ | Beschreibung |
---|---|
Die InputPortBinding mit dieser PortDataReference als Quelle. |
as_input
Erstellt eine InputPortBinding und gibt einen Eingabenamen an (verwendet dabei aber den Standardmodus).
as_input(input_name)
Parameter
Name | Beschreibung |
---|---|
input_name
Erforderlich
|
Verwenden Sie es, um einen Namen für diese Eingabe anzugeben. |
Gibt zurück
Typ | Beschreibung |
---|---|
Die InputPortBinding mit dieser PortDataReference als Quelle. |
as_mount
Verwendet PortDataReference über den Modus „mount“ als Schritteingabe.
as_mount(input_name=None)
Parameter
Name | Beschreibung |
---|---|
input_name
|
Verwenden Sie es, um einen Namen für diese Eingabe anzugeben. Standardwert: None
|
Gibt zurück
Typ | Beschreibung |
---|---|
Die InputPortBinding mit dieser PortDataReference als Quelle. |
create_input_binding
Erstellt die Eingabebindung mit dieser PortDataReference als Quelle.
create_input_binding(input_name=None, mode=None, path_on_compute=None, overwrite=None)
Parameter
Name | Beschreibung |
---|---|
input_name
|
Der Name der Eingabe. Standardwert: None
|
mode
|
Der Modus für den Zugriff auf PortDataReference („mount“ oder „download“). Standardwert: None
|
path_on_compute
|
Für den „download“-Modus. Der Pfad auf dem Computeziel, in dem sich die Daten befinden werden. Standardwert: None
|
overwrite
|
Gibt für den Modus „download“ an, ob vorhandene Daten überschrieben werden. Standardwert: None
|
Gibt zurück
Typ | Beschreibung |
---|---|
Die InputPortBinding mit dieser PortDataReference als Quelle. |
download
Lädt die durch PortDataReference dargestellten Daten herunter.
download(local_path, overwrite=None, show_progress=None)
Parameter
Name | Beschreibung |
---|---|
local_path
Erforderlich
|
Lokaler Pfad, der als Downloadziel verwendet werden soll. |
overwrite
|
TRUE gibt an, dass vorhandene Dateien überschrieben werden. Der Standardwert ist FALSE. Standardwert: None
|
show_progress
|
Zeigt den Fortschritt des Downloads an der Konsole an. Der Standardwert ist TRUE. Standardwert: None
|
Gibt zurück
Typ | Beschreibung |
---|---|
Die Anzahl der erfolgreich heruntergeladenen Dateien |
Attribute
datastore
Ruft den Datenspeicher ab, der PortDataReference zugeordnet ist.
Gibt zurück
Typ | Beschreibung |
---|---|
Das Datenspeicherobjekt. |
datastore_name
Ruft den Namen des Datenspeichers ab, der PortDataReference zugeordnet ist.
Gibt zurück
Typ | Beschreibung |
---|---|
Der Datenspeichername |
name
path_on_datastore
Ruft den Pfad im Datenspeicher für PortDataReference ab.
Gibt zurück
Typ | Beschreibung |
---|---|
Der Pfad zum Datenspeicher. |