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
|
Namnet på det DatabricksCompute-objekt som ska hämtas. |
workspace
Obligatorisk
|
Arbetsyteobjektet som innehåller beräkningsobjektet som ska hämtas. |
name
Obligatorisk
|
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.
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
|
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
|
Azure-resurs-ID för beräkningsresursen som kopplas. |
access_token
Obligatorisk
|
Å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
|
Namnet på resursgruppen där Databricks finns. Standardvärde: None
|
workspace_name
|
Namnet på Databricks-arbetsytan. Standardvärde: None
|
resource_id
|
Azure-resurs-ID för beräkningsresursen som kopplas. Standardvärde: None
|
access_token
Obligatorisk
|
Å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 |
---|---|