ParallelTask 類別

平行工作。

繼承

azure.ai.ml.entities._mixins.RestTranslatableMixin

ParallelTask

azure.ai.ml.entities._mixins.DictMixin

ParallelTask

建構函式

ParallelTask(*, type: str | None = None, code: str | None = None, entry_script: str | None = None, program_arguments: str | None = None, model: str | None = None, append_row_to: str | None = None, environment: Environment | str | None = None, **kwargs: Any)

參數

名稱	Description
type 必要	str 平行工作的型別。 可能的值為 'run_function'和 'model'。
code 必要	str 指向原始程式碼的本機或遠端路徑。
entry_script 必要	str 將在多個節點上平行執行的使用者腳本。 這會指定為本機檔案路徑。 entry_script應該包含兩個函式： init() ：此函式應該用於後續推斷的任何昂貴或常見準備，例如將模型還原序列化並載入全域物件。 run(mini_batch)：要平行處理的方法。 每個叫用都會有一個迷你批次。 'mini_batch'：Batch 推斷會叫用 run 方法，並將清單或 Pandas DataFrame 當做引數傳遞至 方法。 如果輸入是 FileDataset，則min_batch中的每個專案都會是檔案路徑，如果輸入是 TabularDataset，則為 Pandas DataFrame。 run () 方法應該會傳回 Pandas DataFrame 或陣列。 針對 append_row output_action，這些傳回的元素會附加至一般輸出檔案。 針對 summary_only，則會忽略元素的內容。 針對所有輸出動作，每個傳回的輸出元素會指出輸入迷你批次中一次成功的輸入元素推斷。 每個平行背景工作進程都會呼叫 init 一次，然後迴圈 執行函 式，直到處理所有迷你批次為止。
program_arguments 必要	str 平行工作的引數。
model 必要	str 平行工作的模型。
append_row_to 必要	str run () 方法調用所輸出的所有值都會匯總成一個唯一檔案，該檔案會在輸出位置中建立。 如果未設定，則會叫用 'summary_only'，這表示使用者腳本應該儲存輸出本身。
environment 必要	Union[Environment, str] 定型作業將在其中執行的環境。

僅限關鍵字參數

名稱	Description
type 必要
code 必要
entry_script 必要
program_arguments 必要
model 必要
append_row_to 必要
environment 必要

方法

get
has_key
items
keys
update
values

get

get(key: Any, default: Any | None = None) -> Any

參數

名稱	Description
key 必要
default	預設值: None

has_key

has_key(k: Any) -> bool

參數

名稱	Description
k 必要

items

items() -> list

keys

keys() -> list

update

update(*args: Any, **kwargs: Any) -> None

values

values() -> list