DatabricksCompute Clase
Administra un destino de proceso de Databricks en Azure Machine Learning.
Azure Databricks es un entorno basado en Apache Spark de la nube de Azure. Se puede usar como destino de proceso con una canalización de Azure Machine Learning. Para más información, consulte ¿Qué son los destinos de proceso en Azure Machine Learning?
Constructor ComputeTarget de clase.
Recupere una representación en la nube de un objeto Compute asociado al área de trabajo proporcionada. Devuelve una instancia de una clase secundaria correspondiente al tipo específico del objeto Compute recuperado.
- Herencia
-
DatabricksCompute
Constructor
DatabricksCompute(workspace, name)
Parámetros
Nombre | Description |
---|---|
workspace
Requerido
|
Objeto de área de trabajo que contiene el objeto DatabricksCompute que se recuperará. |
name
Requerido
|
Nombre del objeto DatabricksCompute que se recuperará. |
workspace
Requerido
|
Objeto de área de trabajo que contiene el objeto Compute que se recuperará. |
name
Requerido
|
Nombre del objeto Compute que se va a recuperar. |
Comentarios
En el ejemplo siguiente se muestra cómo asociar Azure Databricks como destino de proceso.
# 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)
El ejemplo completo está disponible en 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.
Métodos
attach |
EN DESUSO. Use el método Asocie un recurso de proceso de Databricks existente con el área de trabajo proporcionada. |
attach_configuration |
Crea un objeto de configuración para asociar un destino de proceso de Databricks. |
delete |
No se admite la eliminación para un objeto DatabricksCompute. En su lugar, use detach. |
deserialize |
Convierte un objeto JSON en un objeto DatabricksCompute. |
detach |
Desasocia el objeto Databricks de su área de trabajo asociada. Los objetos subyacentes de la nube no se eliminan, solo se quita la asociación. |
get_credentials |
Recupera las credenciales del destino de Databricks. |
refresh_state |
Realiza una actualización local de las propiedades del objeto. Este método actualiza las propiedades en función del estado actual del objeto de nube correspondiente. Se usa principalmente para el sondeo manual del estado de proceso. |
serialize |
Convierte este objeto DatabricksCompute en un diccionario serializado JSON. |
attach
EN DESUSO. Use el método attach_configuration
en su lugar.
Asocie un recurso de proceso de Databricks existente con el área de trabajo proporcionada.
static attach(workspace, name, resource_id, access_token)
Parámetros
Nombre | Description |
---|---|
workspace
Requerido
|
Objeto de área de trabajo con el que se asociará el recurso de proceso. |
name
Requerido
|
Nombre que se asociará al recurso de proceso dentro del área de trabajo proporcionada. No tiene que coincidir con el nombre del recurso de proceso que se va a asociar. |
resource_id
Requerido
|
Id. de recurso de Azure para el recurso de proceso que se asocia. |
access_token
Requerido
|
Token de acceso para el recurso que se asocia. |
Devoluciones
Tipo | Description |
---|---|
Representación del objeto DatabricksCompute del objeto de proceso. |
Excepciones
Tipo | Description |
---|---|
attach_configuration
Crea un objeto de configuración para asociar un destino de proceso de Databricks.
static attach_configuration(resource_group=None, workspace_name=None, resource_id=None, access_token='')
Parámetros
Nombre | Description |
---|---|
resource_group
|
Nombre del grupo de recursos en el que se encuentra Databricks. Valor predeterminado: None
|
workspace_name
|
Nombre de área de trabajo de Databricks. Valor predeterminado: None
|
resource_id
|
Id. de recurso de Azure para el recurso de proceso que se asocia. Valor predeterminado: None
|
access_token
Requerido
|
Token de acceso para el recurso de proceso que se asocia. |
Devoluciones
Tipo | Description |
---|---|
Objeto de configuración que se usará al asociar un objeto Compute. |
Excepciones
Tipo | Description |
---|---|
delete
No se admite la eliminación para un objeto DatabricksCompute. En su lugar, use detach.
delete()
Excepciones
Tipo | Description |
---|---|
deserialize
Convierte un objeto JSON en un objeto DatabricksCompute.
static deserialize(workspace, object_dict)
Parámetros
Nombre | Description |
---|---|
workspace
Requerido
|
Objeto de área de trabajo al que está asociado el objeto DatabricksCompute. |
object_dict
Requerido
|
Objeto JSON que se va a convertir en un objeto DatabricksCompute. |
Devoluciones
Tipo | Description |
---|---|
Representación de DatabricksCompute del objeto JSON proporcionado. |
Excepciones
Tipo | Description |
---|---|
Comentarios
Genera una excepción ComputeTargetException si el área de trabajo proporcionada no es el área de trabajo a la que está asociado el proceso.
detach
Desasocia el objeto Databricks de su área de trabajo asociada.
Los objetos subyacentes de la nube no se eliminan, solo se quita la asociación.
detach()
Excepciones
Tipo | Description |
---|---|
get_credentials
Recupera las credenciales del destino de Databricks.
get_credentials()
Devoluciones
Tipo | Description |
---|---|
Credenciales del destino de Databricks. |
Excepciones
Tipo | Description |
---|---|
refresh_state
Realiza una actualización local de las propiedades del objeto.
Este método actualiza las propiedades en función del estado actual del objeto de nube correspondiente. Se usa principalmente para el sondeo manual del estado de proceso.
refresh_state()
Excepciones
Tipo | Description |
---|---|
serialize
Convierte este objeto DatabricksCompute en un diccionario serializado JSON.
serialize()
Devoluciones
Tipo | Description |
---|---|
Representación JSON de este objeto DatabricksCompute. |
Excepciones
Tipo | Description |
---|---|