Parallel Osztály

A párhuzamos csomópont alaposztálya, amelyet a párhuzamos összetevők verzióhasználatához használnak.

Ezt az osztályt nem szabad közvetlenül példányosítani. Ehelyett a builder függvényből kell létrehoznia: párhuzamos.

Öröklődés

azure.ai.ml.entities._builders.base_node.BaseNode

Parallel

azure.ai.ml.entities._job.pipeline._io.mixin.NodeWithGroupInputMixin

Parallel

Konstruktor

Parallel(*, component: ParallelComponent | str, compute: str | None = None, inputs: Dict[str, NodeOutput | Input | str | bool | int | float | Enum] | None = None, outputs: Dict[str, str | Output] | None = None, retry_settings: Dict[str, RetrySettings | str] | None = None, logging_level: str | None = None, max_concurrency_per_instance: int | None = None, error_threshold: int | None = None, mini_batch_error_threshold: int | None = None, input_data: str | None = None, task: Dict[str, ParallelTask | str] | None = None, partition_keys: List | None = None, mini_batch_size: int | None = None, resources: JobResourceConfiguration | None = None, environment_variables: Dict | None = None, **kwargs)

Paraméterek

component

<xref:azure.ai.ml.entities._component.parallel_component.parallelComponent>

Kötelező

A lépéshez futtatandó párhuzamos összetevő/feladat azonosítója vagy példánya

name

str

Kötelező

A párhuzamos neve

description

str

Kötelező

A commad leírása

tags

dict[str, str]

Kötelező

Címkeszótár. Címkék hozzáadhatók, eltávolíthatók és frissíthetők

properties

dict[str, str]

Kötelező

A feladattulajdonság szótára

display_name

str

Kötelező

A feladat megjelenítendő neve

retry_settings

BatchRetrySettings

Kötelező

A párhuzamos feladatfuttatás sikertelen újrapróbálkozási művelete

logging_level

str

Kötelező

A naplózási szint nevének sztringje

max_concurrency_per_instance

int

Kötelező

Az egyes számítási példányok maximális párhuzamossági beállítása

error_threshold

int

Kötelező

Az elemfeldolgozási hibák számát figyelmen kívül kell hagyni

mini_batch_error_threshold

int

Kötelező

A minimális kötegfeldolgozási hibák számát figyelmen kívül kell hagyni

task

ParallelTask

Kötelező

A párhuzamos tevékenység

mini_batch_size

str

Kötelező

A FileDataset bemenete esetén ez a mező azoknak a fájloknak a számát adja meg, amelyet a felhasználói szkript egyetlen futtatási() hívásban képes feldolgozni. A TabularDataset bemenet esetében ez a mező a felhasználói szkript által egy futtatási() hívás során feldolgozható adatok hozzávetőleges mérete. Példaértékek: 1024, 1024 KB, 10 MB és 1 GB. (Nem kötelező, az alapértelmezett érték a FileDataset 10 fájlja, a TabularDataset esetében pedig 1 MB.) Ezt az értéket a PipelineParameter segítségével lehet beállítani

partition_keys

List

Kötelező

Az adathalmaz mini kötegekre való particionálásához használt kulcsok. Ha meg van adva, az azonos kulccsal rendelkező adatok ugyanabba a mini kötegbe lesznek particionálva. Ha partition_keys és mini_batch_size is meg van adva, a partíciókulcsok érvénybe lépnek. A bemenet(ek)nek particionált adathalmaz(ok)nak kell lenniük, a partition_keys pedig minden bemeneti adatkészlet kulcsainak egy részhalmazának kell lennie ahhoz, hogy ez működjön.

input_data

str

Kötelező

A bemeneti adatok

inputs

dict

Kötelező

Az összetevő/feladat bemenetei

outputs

dict

Kötelező

Az összetevő/feladat kimenetei

Metódusok

clear
copy
dump	A feladat tartalmát YAML formátumban egy fájlba alakítja.
fromkeys	Hozzon létre egy új szótárat, amely tartalmazza az iterálásból származó kulcsokat és az értékre beállított értékeket.
get	Adja vissza a kulcs értékét, ha a kulcs a szótárban van, máskülönben alapértelmezés szerint.
items
keys
pop	Ha a kulcs nem található, adja vissza az alapértelmezett értéket, ha meg van adva; ellenkező esetben hozzon létre egy KeyErrort.
popitem	Távolítsa el és adja vissza a (kulcs, érték) párokat 2-rekordként. A párok LIFO -sorrendben (utolsó, első ki- és befelé) lesznek visszaadva. Emeli a KeyErrort, ha a diktálás üres.
set_resources	Állítsa be a párhuzamos feladat erőforrásait.
setdefault	Az alapértelmezett értékkel rendelkező kulcs beszúrása, ha a kulcs nem szerepel a szótárban. Adja vissza a kulcs értékét, ha a kulcs a szótárban van, máskülönben alapértelmezés szerint.
update	Ha az E jelen van, és .keys() metódussal rendelkezik, akkor a k esetében az E: D[k] = E[k] Ha az E jelen van, és nem rendelkezik .keys() metódussal, akkor a következőt teszi: k esetén v az E: D[k] = v Mindkét esetben ezt követi a következő: a k in F: D[k] = F[k]
values

clear

clear() -> None.  Remove all items from D.

copy

copy() -> a shallow copy of D

dump

A feladat tartalmát YAML formátumban egy fájlba alakítja.

dump(dest: str | PathLike | IO, **kwargs) -> None

Paraméterek

dest

Union[<xref:PathLike>, str, IO[AnyStr]]

Kötelező

A YAML-tartalom írásához használt helyi elérési út vagy fájlstream. Ha a dest fájlelérési út, a rendszer új fájlt hoz létre. Ha a dest egy megnyitott fájl, a fájl közvetlenül a fájlba lesz írva.

kwargs

dict

A YAML szerializálónak továbbadandó további argumentumok.

Kivételek

FileExistsError

Ha a dest fájlelérési út, a fájl már létezik.

IOError

Fel van emelve, ha a dest egy nyitott fájl, és a fájl nem írható.

fromkeys

Hozzon létre egy új szótárat, amely tartalmazza az iterálásból származó kulcsokat és az értékre beállított értékeket.

fromkeys(value=None, /)

Paraméterek

type

Kötelező

iterable

Kötelező

value

alapértelmezett érték: None

get

Adja vissza a kulcs értékét, ha a kulcs a szótárban van, máskülönben alapértelmezés szerint.

get(key, default=None, /)

Paraméterek

key

Kötelező

default

alapértelmezett érték: None

items

items() -> a set-like object providing a view on D's items

keys

keys() -> a set-like object providing a view on D's keys

pop

Ha a kulcs nem található, adja vissza az alapértelmezett értéket, ha meg van adva; ellenkező esetben hozzon létre egy KeyErrort.

pop(k, [d]) -> v, remove specified key and return the corresponding value.

popitem

Távolítsa el és adja vissza a (kulcs, érték) párokat 2-rekordként.

A párok LIFO -sorrendben (utolsó, első ki- és befelé) lesznek visszaadva. Emeli a KeyErrort, ha a diktálás üres.

popitem()

set_resources

Állítsa be a párhuzamos feladat erőforrásait.

set_resources(*, instance_type: str | List[str] | None = None, instance_count: int | None = None, properties: Dict | None = None, docker_args: str | None = None, shm_size: str | None = None, **kwargs)

Paraméterek

instance_type

str vagy list[str]

A számítási cél által támogatott példánytípus vagy példánytípusok listája.

instance_count

int

A számítási cél által használt példányok vagy csomópontok száma.

properties

dict

Az erőforrások tulajdonságszótára.

docker_args

str

További argumentumok a Docker-futtatási parancsnak való továbbításhoz.

shm_size

str

A Docker-tároló megosztott memóriablokkjának mérete.

setdefault

Az alapértelmezett értékkel rendelkező kulcs beszúrása, ha a kulcs nem szerepel a szótárban.

Adja vissza a kulcs értékét, ha a kulcs a szótárban van, máskülönben alapértelmezés szerint.

setdefault(key, default=None, /)

Paraméterek

key

Kötelező

default

alapértelmezett érték: None

update

Ha az E jelen van, és .keys() metódussal rendelkezik, akkor a k esetében az E: D[k] = E[k] Ha az E jelen van, és nem rendelkezik .keys() metódussal, akkor a következőt teszi: k esetén v az E: D[k] = v Mindkét esetben ezt követi a következő: a k in F: D[k] = F[k]

update([E], **F) -> None.  Update D from dict/iterable E and F.

values

values() -> an object providing a view on D's values

Attribútumok

base_path

Az erőforrás alapútvonala.

Válaszok

Az erőforrás alapútvonala.

Visszatérési típus

str

component

A párhuzamos feladat összetevőjének lekérése.

Válaszok

A párhuzamos feladat összetevője.

Visszatérési típus

str,

ParallelComponent

creation_context

Az erőforrás létrehozási környezete.

Válaszok

Az erőforrás létrehozási metaadatai.

Visszatérési típus

Optional[SystemData]

id

Az erőforrás azonosítója.

Válaszok

Az erőforrás globális azonosítója, egy Azure Resource Manager (ARM) azonosító.

Visszatérési típus

Optional[str]

inputs

Kérje le az objektum bemeneteit.

Válaszok

Az objektum bemeneteit tartalmazó szótár.

Visszatérési típus

Dict[str, Union[Input, str, bool, int, float]]

log_files

Feladat kimeneti fájljai.

Válaszok

A naplónevek és URL-címek szótára.

Visszatérési típus

Optional[Dict[str, str]]

name

Kérje le a csomópont nevét.

Válaszok

A csomópont neve.

Visszatérési típus

str

outputs

Kérje le az objektum kimeneteit.

Válaszok

Az objektum kimeneteit tartalmazó szótár.

Visszatérési típus

Dict[str, Union[str, Output]]

resources

Kérje le a párhuzamos feladat erőforrás-konfigurációját.

Válaszok

A párhuzamos feladat erőforrás-konfigurációja.

Visszatérési típus

JobResourceConfiguration

retry_settings

Kérje le a párhuzamos feladat újrapróbálkozési beállításait.

Válaszok

A párhuzamos feladat újrapróbálkozása.

Visszatérési típus

RetrySettings

status

A feladat állapota.

A visszaadott gyakori értékek közé tartozik a "Futtatás", a "Kész" és a "Sikertelen". Minden lehetséges érték a következő:

• NotStarted – Ez egy ideiglenes állapot, amelyben az ügyféloldali Run objektumok a felhőbeküldés előtt találhatók.

• Indítás – A futtatás elkezdődött a felhőben való feldolgozásnak. A hívó ezen a ponton futtatási azonosítóval rendelkezik.

• Kiépítés – Igény szerinti számítás jön létre egy adott feladatbeküldéshez.

• Előkészítés – A futtató környezet előkészítése folyamatban van, és két fázis egyikében van:

  • Docker-rendszerkép buildelése

  • conda-környezet beállítása

• Queued – A feladat várólistára kerül a számítási célon. A BatchAI-ban például a feladat várólistán van

  amíg az összes kért csomópont készen áll.

• Futtatás – A feladat elkezdett futni a számítási célon.

• Véglegesítés – A felhasználói kód végrehajtása befejeződött, és a futtatás a feldolgozás utáni fázisban van.

• CancelRequested – A feladat lemondását kérték.

• Befejeződött – A futtatás sikeresen befejeződött. Ez magában foglalja a felhasználói kód végrehajtását és a futtatást is

  utófeldolgozási fázisok.

• Sikertelen – A futtatás sikertelen volt. Általában a Futtatás hiba tulajdonsága adja meg a részleteket, hogy miért.

• Megszakítva – Egy lemondási kérést követ, és azt jelzi, hogy a futtatás sikeresen megszakadt.

• NotKiszolgáló – Azon futtatások esetében, amelyeken engedélyezve van a szívverés, a rendszer nem küldött szívverést a közelmúltban.

Válaszok

A feladat állapota.

Visszatérési típus

Optional[str]

studio_url

Azure ML Studio-végpont.

Válaszok

A feladat részletei lap URL-címe.

Visszatérési típus

Optional[str]

task

A párhuzamos feladat lekérése.

Válaszok

A párhuzamos tevékenység.

Visszatérési típus

ParallelTask

type

A feladat típusa.

Válaszok

A feladat típusa.

Visszatérési típus

Optional[str]