DatabricksCompute Classe
Gerencia um destino de computação Databricks no Azure Machine Learning.
O Azure Databricks é um ambiente baseado no Apache Spark na nuvem do Azure. Pode ser utilizado como 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?
Classe ComputeTarget construtor.
Recupere uma representação na nuvem de um objeto Compute associado ao espaço de trabalho fornecido. Retorna uma instância de uma classe filho correspondente ao tipo específico do objeto Compute recuperado.
Construtor
DatabricksCompute(workspace, name)
Parâmetros
| Name | Description |
|---|---|
|
workspace
Necessário
|
O objeto de espaço de trabalho que contém o objeto DatabricksCompute a ser recuperado. |
|
name
Necessário
|
O nome do objeto DatabricksCompute a ser recuperado. |
|
workspace
Necessário
|
O objeto de espaço de trabalho que contém o objeto Compute a ser recuperado. |
|
name
Necessário
|
O nome do objeto Compute a ser recuperado. |
Observações
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)
A amostra completa 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 Associe um recurso de computação Databricks existente ao espaço de trabalho fornecido. |
| attach_configuration |
Crie um objeto de configuração para anexar um destino de computação Databricks. |
| delete |
Não há suporte para Delete para um objeto DatabricksCompute. Utilize detach em substituição. |
| deserialize |
Converter um objeto JSON em um objeto DatabricksCompute. |
| detach |
Desanexa o objeto Databricks de seu espaço de trabalho associado. Os objetos de nuvem subjacentes não são excluídos, apenas a associação é removida. |
| get_credentials |
Recupere as credenciais para o destino Databricks. |
| refresh_state |
Execute uma atualização in-loco das propriedades do objeto. Este 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 este objeto DatabricksCompute em um dicionário serializado JSON. |
attach
PRETERIDO. Use o attach_configuration método em vez disso.
Associe um recurso de computação Databricks existente ao espaço de trabalho fornecido.
static attach(workspace, name, resource_id, access_token)
Parâmetros
| Name | Description |
|---|---|
|
workspace
Necessário
|
O objeto de espaço de trabalho ao qual associar o recurso de computação. |
|
name
Necessário
|
O nome a ser associado ao recurso de computação dentro do espaço de trabalho fornecido. Não precisa corresponder ao nome do recurso de computação a ser anexado. |
|
resource_id
Necessário
|
A ID do recurso do Azure para o recurso de computação que está sendo anexado. |
|
access_token
Necessário
|
O token de acesso para o recurso que está sendo anexado. |
Devoluções
| Tipo | Description |
|---|---|
|
Uma representação do 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 Databricks.
static attach_configuration(resource_group=None, workspace_name=None, resource_id=None, access_token='')
Parâmetros
| Name | Description |
|---|---|
|
resource_group
|
O nome do grupo de recursos no qual o Databricks está localizado. Default value: None
|
|
workspace_name
|
O nome do espaço de trabalho Databricks. Default value: None
|
|
resource_id
|
A ID do recurso do Azure para o recurso de computação que está sendo anexado. Default value: None
|
|
access_token
Necessário
|
O token de acesso para o recurso de computação que está sendo anexado. |
Devoluções
| Tipo | Description |
|---|---|
|
Um objeto de configuração a ser usado ao anexar um objeto Compute. |
delete
Não há suporte para Delete para um objeto DatabricksCompute. Utilize detach em substituição.
delete()
Exceções
| Tipo | Description |
|---|---|
deserialize
Converter um objeto JSON em um objeto DatabricksCompute.
static deserialize(workspace, object_dict)
Parâmetros
| Name | Description |
|---|---|
|
workspace
Necessário
|
O objeto de espaço de trabalho ao qual o objeto DatabricksCompute está associado. |
|
object_dict
Necessário
|
Um objeto JSON para converter em um objeto DatabricksCompute. |
Devoluções
| Tipo | Description |
|---|---|
|
A representação DatabricksCompute do objeto JSON fornecido. |
Exceções
| Tipo | Description |
|---|---|
Observações
Gera um ComputeTargetException se o espaço de trabalho fornecido não for o espaço de trabalho ao qual a computação está associada.
detach
Desanexa o objeto Databricks de seu espaço de trabalho associado.
Os 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 Databricks.
get_credentials()
Devoluções
| Tipo | Description |
|---|---|
|
As credenciais para o destino Databricks. |
Exceções
| Tipo | Description |
|---|---|
refresh_state
Execute uma atualização in-loco das propriedades do objeto.
Este 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 este objeto DatabricksCompute em um dicionário serializado JSON.
serialize()
Devoluções
| Tipo | Description |
|---|---|
|
A representação JSON deste objeto DatabricksCompute. |