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, confira 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 Compute associado ao workspace fornecido. Retorna uma instância de uma classe filho correspondente ao tipo específico do objeto Compute recuperado.
- Herança
-
DatabricksCompute
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 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 |
PRETERIDO. Use o método Associa um recurso de computação Databricks existente ao workspace fornecido. |
attach_configuration |
Cria um objeto de configuração para anexar um destino de computação do Databricks. |
delete |
Não há suporte de exclusão para um objeto DatabricksCompute. Use detach em vez disso. |
deserialize |
Converte um objeto JSON em um objeto DatabricksCompute. |
detach |
Desanexa o objeto Databricks do seu workspace associado. Os objetos de nuvem subjacentes não são excluídos, apenas a associação é removida. |
get_credentials |
Recupera as credenciais para o destino do Databricks. |
refresh_state |
Execute uma atualização local 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 |
Converte esse objeto DatabricksCompute em um dicionário serializado JSON. |
attach
PRETERIDO. Use o método attach_configuration
em seu lugar.
Associa um recurso de computação 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. Esse nome 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
Cria 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 de computação. |
Exceções
Tipo | Description |
---|---|
delete
Não há suporte de exclusão para um objeto DatabricksCompute. Use detach em vez disso.
delete()
Exceções
Tipo | Description |
---|---|
deserialize
Converte 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 para converter em um objeto DatabricksCompute. |
Retornos
Tipo | Description |
---|---|
A representação DatabricksCompute do objeto JSON fornecido. |
Exceções
Tipo | Description |
---|---|
Comentários
Gera uma ComputeTargetException se o workspace fornecido não é o workspace ao qual a computação está associada.
detach
Desanexa o objeto Databricks do seu workspace associado.
Os objetos de nuvem subjacentes não são excluídos, apenas a associação é removida.
detach()
Exceções
Tipo | Description |
---|---|
get_credentials
Recupera as credenciais para o destino do Databricks.
get_credentials()
Retornos
Tipo | Description |
---|---|
As credenciais do destino do Databricks. |
Exceções
Tipo | Description |
---|---|
refresh_state
Execute uma atualização local 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()
Exceções
Tipo | Description |
---|---|
serialize
Converte esse objeto DatabricksCompute em um dicionário serializado JSON.
serialize()
Retornos
Tipo | Description |
---|---|
A representação JSON desse objeto DatabricksCompute. |
Exceções
Tipo | Description |
---|---|