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?

Class ComputeTarget-konstruktor.

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.

Konstruktor

DatabricksCompute(workspace, name)

Parametrar

Name Description
workspace
Obligatorisk
Workspace

Arbetsyteobjektet som innehåller databricksCompute-objektet som ska hämtas.
name
Obligatorisk
str

Namnet på databricksCompute-objektet som ska hämtas.
workspace
Obligatorisk
Workspace

Arbetsyteobjektet som innehåller compute-objektet som ska hämtas.
name
Obligatorisk
str

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

Kommentarer

I följande exempel visas hur du bifogar 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 ansluta 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
Workspace

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å den beräkningsresurs som ska kopplas.
resource_id
Obligatorisk
str

Azure-resurs-ID:t för beräkningsresursen som kopplas.
access_token
Obligatorisk
str

Åtkomsttoken för resursen som kopplas.

Returer

Typ Description
DatabricksCompute

En DatabricksCompute-objektrepresentation av beräkningsobjektet.

Undantag

Typ Description
ComputeTargetException

attach_configuration

Skapa ett konfigurationsobjekt för att ansluta 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:t för beräkningsresursen som kopplas.

Standardvärde: None
access_token
Obligatorisk
str

Åtkomsttoken för beräkningsresursen som kopplas.

Returer

Typ Description
DatabricksAttachConfiguration

Ett konfigurationsobjekt som ska användas vid anslutning av ett Compute-objekt.

delete

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

delete()

Undantag

Typ Description
ComputeTargetException

deserialize

Konvertera ett JSON-objekt till ett DatabricksCompute-objekt.

static deserialize(workspace, object_dict)

Parametrar

Name Description
workspace
Obligatorisk
Workspace

Arbetsyteobjektet som DatabricksCompute-objektet är associerat med.
object_dict
Obligatorisk
dict

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

Returer

Typ Description
DatabricksCompute

DatabricksCompute-representationen av det angivna JSON-objektet.

Undantag

Typ Description
ComputeTargetException

Kommentarer

Genererar en ComputeTargetException om den angivna arbetsytan inte är den arbetsyta som beräkning ä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
ComputeTargetException

get_credentials

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

get_credentials()

Returer

Typ Description
dict

Autentiseringsuppgifterna för Databricks-målet.

Undantag

Typ Description
ComputeTargetException

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()

serialize

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

serialize()

Returer

Typ Description
dict

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