Compartir a través de

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.

Constructor

DatabricksCompute(workspace, name)

Parámetros

Nombre Description
workspace
Requerido
Workspace

Objeto de área de trabajo que contiene el objeto DatabricksCompute que se va a recuperar.
name
Requerido
str

Nombre del objeto DatabricksCompute que se va a recuperar.
workspace
Requerido
Workspace

Objeto de área de trabajo que contiene el objeto Compute que se va a recuperar.
name
Requerido
str

Nombre del objeto Compute que se va a recuperar.

Comentarios

En el ejemplo siguiente se muestra cómo adjuntar 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

OBSOLESCENTE. Use el attach_configuration método en su lugar.

Asocie un recurso de proceso de Databricks existente al área de trabajo proporcionada.
attach_configuration

Cree un objeto de configuración para adjuntar un destino de proceso de Databricks.
delete

La eliminación no se admite para un objeto DatabricksCompute. En su lugar, use detach.
deserialize

Convierta un objeto JSON en un objeto DatabricksCompute.
detach

Desasocia el objeto Databricks de su área de trabajo asociada.

Los objetos en la nube subyacentes no se eliminan, solo se quita la asociación.
get_credentials

Recupere las credenciales del destino de Databricks.
refresh_state

Realice 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. Esto se usa principalmente para el sondeo manual del estado de proceso.
serialize

Convierta este objeto DatabricksCompute en un diccionario serializado JSON.

attach

OBSOLESCENTE. Use el attach_configuration método en su lugar.

Asocie un recurso de proceso de Databricks existente al área de trabajo proporcionada.

static attach(workspace, name, resource_id, access_token)

Parámetros

Nombre Description
workspace
Requerido
Workspace

Objeto de área de trabajo al que se va a asociar el recurso de proceso.
name
Requerido
str

Nombre que se va a 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
str

Identificador de recurso de Azure para el recurso de proceso que se va a adjuntar.
access_token
Requerido
str

Token de acceso para el recurso que se va a adjuntar.

Devoluciones

Tipo Description
DatabricksCompute

Representación de objeto DatabricksCompute del objeto compute.

Excepciones

Tipo Description
ComputeTargetException

attach_configuration

Cree un objeto de configuración para adjuntar 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
str

Nombre del grupo de recursos en el que se encuentra Databricks.

Valor predeterminado: None
workspace_name
str

Nombre del área de trabajo de Databricks.

Valor predeterminado: None
resource_id
str

Identificador de recurso de Azure para el recurso de proceso que se va a adjuntar.

Valor predeterminado: None
access_token
Requerido
str

Token de acceso para el recurso de proceso que se está adjuntando.

Devoluciones

Tipo Description
DatabricksAttachConfiguration

Objeto de configuración que se va a usar al adjuntar un objeto Compute.

delete

La eliminación no se admite para un objeto DatabricksCompute. En su lugar, use detach.

delete()

Excepciones

Tipo Description
ComputeTargetException

deserialize

Convierta un objeto JSON en un objeto DatabricksCompute.

static deserialize(workspace, object_dict)

Parámetros

Nombre Description
workspace
Requerido
Workspace

Objeto de área de trabajo al que está asociado el objeto DatabricksCompute.
object_dict
Requerido
dict

Objeto JSON que se va a convertir en un objeto DatabricksCompute.

Devoluciones

Tipo Description
DatabricksCompute

Representación databricksCompute del objeto JSON proporcionado.

Excepciones

Tipo Description
ComputeTargetException

Comentarios

Genera un 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 en la nube subyacentes no se eliminan, solo se quita la asociación.

detach()

Excepciones

Tipo Description
ComputeTargetException

get_credentials

Recupere las credenciales del destino de Databricks.

get_credentials()

Devoluciones

Tipo Description
dict

Credenciales para el destino de Databricks.

Excepciones

Tipo Description
ComputeTargetException

refresh_state

Realice 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. Esto se usa principalmente para el sondeo manual del estado de proceso.

refresh_state()

serialize

Convierta este objeto DatabricksCompute en un diccionario serializado JSON.

serialize()

Devoluciones

Tipo Description
dict

Representación JSON de este objeto DatabricksCompute.