DatabricksCompute Classe
Gerencia um destino de computação do Databricks no Azure Machine Learning.
As Azure Databricks são um ambiente baseado em Apache Spark na nuvem do Azure. Ele pode ser usado como um destino de computação com um pipeline do Azure Machine Learning. Para obter mais informações, consulte O que são destinos de computação no Azure Machine Learning?
Construtor computeTarget de classe.
Recupere uma representação na nuvem de um objeto de computação associado ao workspace fornecido. Retorna uma instância de uma classe filho correspondente ao tipo específico do objeto compute recuperado.
Construtor
DatabricksCompute(workspace, name)
Parâmetros
| Nome | Description |
|---|---|
|
workspace
Obrigatório
|
O objeto de workspace que contém o objeto DatabricksCompute a ser recuperado. |
|
name
Obrigatório
|
O nome do objeto DatabricksCompute a ser recuperado. |
|
workspace
Obrigatório
|
O objeto de workspace que contém o objeto Compute a ser recuperado. |
|
name
Obrigatório
|
O nome do objeto Compute a ser recuperado. |
Comentários
O exemplo a seguir mostra como anexar o Azure Databricks como um destino de computação.
# 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)
O exemplo completo está disponível em 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 |
DEPRECADO. Em vez disso, use o Associe um recurso de computação do Databricks existente ao workspace fornecido. |
| attach_configuration |
Crie um objeto de configuração para anexar um destino de computação do Databricks. |
| delete |
Não há suporte para Exclusão para um objeto DatabricksCompute. Use detach em seu lugar. |
| deserialize |
Converta um objeto JSON em um objeto DatabricksCompute. |
| detach |
Desanexa o objeto Databricks de seu workspace associado. Objetos de nuvem subjacentes não são excluídos, apenas a associação é removida. |
| get_credentials |
Recupere as credenciais para o destino do Databricks. |
| refresh_state |
Execute uma atualização in-loco das propriedades do objeto. Esse método atualiza as propriedades com base no estado atual do objeto de nuvem correspondente. Isso é usado principalmente para sondagem manual do estado de computação. |
| serialize |
Converta esse objeto DatabricksCompute em um dicionário serializado JSON. |
attach
DEPRECADO. Em vez disso, use o attach_configuration método.
Associe um recurso de computação do Databricks existente ao workspace fornecido.
static attach(workspace, name, resource_id, access_token)
Parâmetros
| Nome | Description |
|---|---|
|
workspace
Obrigatório
|
O objeto de workspace ao qual associar o recurso de computação. |
|
name
Obrigatório
|
O nome a ser associado ao recurso de computação dentro do workspace fornecido. Não precisa corresponder ao nome do recurso de computação a ser anexado. |
|
resource_id
Obrigatório
|
A ID do recurso do Azure para o recurso de computação que está sendo anexado. |
|
access_token
Obrigatório
|
O token de acesso para o recurso que está sendo anexado. |
Retornos
| Tipo | Description |
|---|---|
|
Uma representação de objeto DatabricksCompute do objeto de computação. |
Exceções
| Tipo | Description |
|---|---|
attach_configuration
Crie um objeto de configuração para anexar um destino de computação do Databricks.
static attach_configuration(resource_group=None, workspace_name=None, resource_id=None, access_token='')
Parâmetros
| Nome | Description |
|---|---|
|
resource_group
|
O nome do grupo de recursos no qual o Databricks está localizado. Valor padrão: None
|
|
workspace_name
|
O nome do workspace do Databricks. Valor padrão: None
|
|
resource_id
|
A ID do recurso do Azure para o recurso de computação que está sendo anexado. Valor padrão: None
|
|
access_token
Obrigatório
|
O token de acesso para o recurso de computação que está sendo anexado. |
Retornos
| Tipo | Description |
|---|---|
|
Um objeto de configuração a ser usado ao anexar um objeto compute. |
delete
Não há suporte para Exclusão para um objeto DatabricksCompute. Use detach em seu lugar.
delete()
Exceções
| Tipo | Description |
|---|---|
deserialize
Converta um objeto JSON em um objeto DatabricksCompute.
static deserialize(workspace, object_dict)
Parâmetros
| Nome | Description |
|---|---|
|
workspace
Obrigatório
|
O objeto de workspace ao qual o objeto DatabricksCompute está associado. |
|
object_dict
Obrigatório
|
Um objeto JSON a ser convertido em um objeto DatabricksCompute. |
Retornos
| Tipo | Description |
|---|---|
|
A representação DatabricksCompute do objeto JSON fornecido. |
Exceções
| Tipo | Description |
|---|---|
Comentários
Gera um ComputeTargetException se o workspace fornecido não for o workspace ao qual a computação está associada.
detach
Desanexa o objeto Databricks de seu workspace associado.
Objetos de nuvem subjacentes não são excluídos, apenas a associação é removida.
detach()
Exceções
| Tipo | Description |
|---|---|
get_credentials
Recupere as credenciais para o destino do Databricks.
get_credentials()
Retornos
| Tipo | Description |
|---|---|
|
As credenciais para o destino do Databricks. |
Exceções
| Tipo | Description |
|---|---|
refresh_state
Execute uma atualização in-loco das propriedades do objeto.
Esse método atualiza as propriedades com base no estado atual do objeto de nuvem correspondente. Isso é usado principalmente para sondagem manual do estado de computação.
refresh_state()
serialize
Converta esse objeto DatabricksCompute em um dicionário serializado JSON.
serialize()
Retornos
| Tipo | Description |
|---|---|
|
A representação JSON deste objeto DatabricksCompute. |