Dela via


DatabricksCompute Klass

Hanterar ett Databricks-beräkningsmål i Azure Machine Learning.

Azure Databricks är en Apache Spark-baserad miljö i Azure-molnet. Det kan användas som beräkningsmål med en Azure Machine Learning-pipeline. Mer information finns i Vad är beräkningsmål i Azure Machine Learning?

ComputeTarget-konstruktor för klass.

Hämta en molnrepresentation av ett Compute-objekt som är associerat med den angivna arbetsytan. Returnerar en instans av en underordnad klass som motsvarar den specifika typen av det hämtade beräkningsobjektet.

Arv
DatabricksCompute

Konstruktor

DatabricksCompute(workspace, name)

Parametrar

Name Description
workspace
Obligatorisk

Arbetsyteobjektet som innehåller DatabricksCompute-objektet som ska hämtas.

name
Obligatorisk
str

Namnet på det DatabricksCompute-objekt som ska hämtas.

workspace
Obligatorisk

Arbetsyteobjektet som innehåller beräkningsobjektet som ska hämtas.

name
Obligatorisk
str

Namnet på det Compute-objekt som ska hämtas.

Kommentarer

I följande exempel visas hur du kopplar Azure Databricks som beräkningsmål.


   # Replace with your account info before running.

   db_compute_name=os.getenv("DATABRICKS_COMPUTE_NAME", "<my-databricks-compute-name>") # Databricks compute name
   db_resource_group=os.getenv("DATABRICKS_RESOURCE_GROUP", "<my-db-resource-group>") # Databricks resource group
   db_workspace_name=os.getenv("DATABRICKS_WORKSPACE_NAME", "<my-db-workspace-name>") # Databricks workspace name
   db_access_token=os.getenv("DATABRICKS_ACCESS_TOKEN", "<my-access-token>") # Databricks access token

   try:
       databricks_compute = DatabricksCompute(workspace=ws, name=db_compute_name)
       print('Compute target {} already exists'.format(db_compute_name))
   except ComputeTargetException:
       print('Compute not found, will use below parameters to attach new one')
       print('db_compute_name {}'.format(db_compute_name))
       print('db_resource_group {}'.format(db_resource_group))
       print('db_workspace_name {}'.format(db_workspace_name))
       print('db_access_token {}'.format(db_access_token))

       config = DatabricksCompute.attach_configuration(
           resource_group = db_resource_group,
           workspace_name = db_workspace_name,
           access_token= db_access_token)
       databricks_compute=ComputeTarget.attach(ws, db_compute_name, config)
       databricks_compute.wait_for_completion(True)

Fullständigt exempel är tillgängligt från https://github.com/Azure/MachineLearningNotebooks/blob/master/how-to-use-azureml/machine-learning-pipelines/intro-to-pipelines/aml-pipelines-use-databricks-as-compute-target.ipynb

Metoder

attach

DEPRECATED. attach_configuration Använd metoden i stället.

Associera en befintlig Databricks-beräkningsresurs med den angivna arbetsytan.

attach_configuration

Skapa ett konfigurationsobjekt för att koppla ett Databricks-beräkningsmål.

delete

Borttagning stöds inte för ett DatabricksCompute-objekt. Använd detach i stället.

deserialize

Konvertera ett JSON-objekt till ett DatabricksCompute-objekt.

detach

Kopplar från Databricks-objektet från dess associerade arbetsyta.

Underliggande molnobjekt tas inte bort, endast associationen tas bort.

get_credentials

Hämta autentiseringsuppgifterna för Databricks-målet.

refresh_state

Utför en uppdatering på plats av objektets egenskaper.

Den här metoden uppdaterar egenskaperna baserat på det aktuella tillståndet för motsvarande molnobjekt. Detta används främst för manuell avsökning av beräkningstillstånd.

serialize

Konvertera det här DatabricksCompute-objektet till en JSON-serialiserad ordlista.

attach

DEPRECATED. attach_configuration Använd metoden i stället.

Associera en befintlig Databricks-beräkningsresurs med den angivna arbetsytan.

static attach(workspace, name, resource_id, access_token)

Parametrar

Name Description
workspace
Obligatorisk

Det arbetsyteobjekt som beräkningsresursen ska associeras med.

name
Obligatorisk
str

Namnet som ska associeras med beräkningsresursen på den angivna arbetsytan. Behöver inte matcha namnet på beräkningsresursen som ska kopplas.

resource_id
Obligatorisk
str

Azure-resurs-ID för beräkningsresursen som kopplas.

access_token
Obligatorisk
str

Åtkomsttoken för resursen som kopplas.

Returer

Typ Description

En DatabricksCompute-objektrepresentation av beräkningsobjektet.

Undantag

Typ Description

attach_configuration

Skapa ett konfigurationsobjekt för att koppla ett Databricks-beräkningsmål.

static attach_configuration(resource_group=None, workspace_name=None, resource_id=None, access_token='')

Parametrar

Name Description
resource_group
str

Namnet på resursgruppen där Databricks finns.

Standardvärde: None
workspace_name
str

Namnet på Databricks-arbetsytan.

Standardvärde: None
resource_id
str

Azure-resurs-ID för beräkningsresursen som kopplas.

Standardvärde: None
access_token
Obligatorisk
str

Åtkomsttoken för beräkningsresursen som kopplas.

Returer

Typ Description

Ett konfigurationsobjekt som ska användas när du kopplar ett Compute-objekt.

Undantag

Typ Description

delete

Borttagning stöds inte för ett DatabricksCompute-objekt. Använd detach i stället.

delete()

Undantag

Typ Description

deserialize

Konvertera ett JSON-objekt till ett DatabricksCompute-objekt.

static deserialize(workspace, object_dict)

Parametrar

Name Description
workspace
Obligatorisk

Arbetsyteobjektet som DatabricksCompute-objektet är associerat med.

object_dict
Obligatorisk

Ett JSON-objekt som ska konverteras till ett DatabricksCompute-objekt.

Returer

Typ Description

DatabricksCompute-representationen av det angivna JSON-objektet.

Undantag

Typ Description

Kommentarer

Genererar en ComputeTargetException om den angivna arbetsytan inte är den arbetsyta som Compute är associerad med.

detach

Kopplar från Databricks-objektet från dess associerade arbetsyta.

Underliggande molnobjekt tas inte bort, endast associationen tas bort.

detach()

Undantag

Typ Description

get_credentials

Hämta autentiseringsuppgifterna för Databricks-målet.

get_credentials()

Returer

Typ Description

Autentiseringsuppgifterna för Databricks-målet.

Undantag

Typ Description

refresh_state

Utför en uppdatering på plats av objektets egenskaper.

Den här metoden uppdaterar egenskaperna baserat på det aktuella tillståndet för motsvarande molnobjekt. Detta används främst för manuell avsökning av beräkningstillstånd.

refresh_state()

Undantag

Typ Description

serialize

Konvertera det här DatabricksCompute-objektet till en JSON-serialiserad ordlista.

serialize()

Returer

Typ Description

JSON-representationen av det här DatabricksCompute-objektet.

Undantag

Typ Description