in infrastructure-provisioning/src/general/scripts/azure/edge_terminate.py [0:0]
def terminate_edge_node(resource_group_name, service_base_name, project_tag, subnet_name, vpc_name):
logging.info("Terminating EDGE, notebook and dataengine virtual machines")
try:
for vm in AzureMeta.compute_client.virtual_machines.list(resource_group_name):
try:
if project_tag == vm.tags["project_tag"]:
AzureActions.remove_instance(resource_group_name, vm.name)
logging.info("Instance {} has been terminated".format(vm.name))
except:
pass
except Exception as err:
datalab.fab.append_result("Failed to terminate instance", str(err))
sys.exit(1)
logging.info("Removing network interfaces")
try:
for network_interface in AzureMeta.list_network_interfaces(resource_group_name):
try:
if project_tag == network_interface.tags["project_tag"]:
AzureActions.delete_network_if(resource_group_name, network_interface.name)
logging.info("Network interface {} has been removed".format(network_interface.name))
except:
pass
except Exception as err:
datalab.fab.append_result("Failed to remove network interfaces", str(err))
sys.exit(1)
logging.info("Removing static public IPs")
try:
for static_public_ip in AzureMeta.list_static_ips(resource_group_name):
try:
if project_tag in static_public_ip.tags["project_tag"]:
AzureActions.delete_static_public_ip(resource_group_name, static_public_ip.name)
logging.info("Static public IP {} has been removed".format(static_public_ip.name))
except:
pass
except Exception as err:
datalab.fab.append_result("Failed to remove static IPs", str(err))
sys.exit(1)
logging.info("Removing disks")
try:
for disk in AzureMeta.list_disks(resource_group_name):
try:
if project_tag in disk.tags["project_tag"]:
AzureActions.remove_disk(resource_group_name, disk.name)
logging.info("Disk {} has been removed".format(disk.name))
except:
pass
except Exception as err:
datalab.fab.append_result("Failed to remove disks", str(err))
sys.exit(1)
logging.info("Removing storage account")
try:
for storage_account in AzureMeta.list_storage_accounts(resource_group_name):
try:
if project_tag == storage_account.tags["project_tag"]:
AzureActions.remove_storage_account(resource_group_name, storage_account.name)
logging.info("Storage account {} has been terminated".format(storage_account.name))
except:
pass
except Exception as err:
datalab.fab.append_result("Failed to remove storage accounts", str(err))
sys.exit(1)
# logging.info("Deleting Data Lake Store directory")
# try:
# for datalake in AzureMeta.list_datalakes(resource_group_name):
# try:
# if service_base_name == datalake.tags["SBN"]:
# AzureActions.remove_datalake_directory(datalake.name, project_tag + '-folder')
# logging.info("Data Lake Store directory {} has been deleted".format(project_tag + '-folder'))
# except:
# pass
# except Exception as err:
# datalab.fab.append_result("Failed to remove Data Lake", str(err))
# sys.exit(1)
logging.info("Removing security groups")
try:
for sg in AzureMeta.network_client.network_security_groups.list(resource_group_name):
try:
if project_tag == sg.tags["project_tag"]:
AzureActions.remove_security_group(resource_group_name, sg.name)
logging.info("Security group {} has been terminated".format(sg.name))
except:
pass
except Exception as err:
datalab.fab.append_result("Failed to remove security groups", str(err))
sys.exit(1)
logging.info("Removing private subnet")
try:
AzureActions.remove_subnet(resource_group_name, vpc_name, subnet_name)
logging.info("Private subnet {} has been terminated".format(subnet_name))
except Exception as err:
datalab.fab.append_result("Failed to remove subnet", str(err))
sys.exit(1)