Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -20,6 +20,7 @@
from ._list_sizes import *
from ._list_skus import *
from ._list_vm_resize_options import *
from ._migrate_to_vmss import *
from ._patch import *
from ._perform_maintenance import *
from ._reapply import *
Expand Down
Original file line number Diff line number Diff line change
@@ -0,0 +1,179 @@
# --------------------------------------------------------------------------------------------
# Copyright (c) Microsoft Corporation. All rights reserved.
# Licensed under the MIT License. See License.txt in the project root for license information.
#
# Code generated by aaz-dev-tools
# --------------------------------------------------------------------------------------------

# pylint: skip-file
# flake8: noqa

from azure.cli.core.aaz import *


@register_command(
"vm migrate-to-vmss",
)
class MigrateToVmss(AAZCommand):
"""Migrate a virtual machine from availability set to Flexible Virtual Machine Scale Set.

:example: Migrate a vm to flexible vmss
az vm migrate-to-vmss --resource-group myResourceGroup --vm-name myVMName --target-fault-domain 0 --target-vm-size Standard_D1_v2
"""

_aaz_info = {
"version": "2024-11-01",
"resources": [
["mgmt-plane", "/subscriptions/{}/resourcegroups/{}/providers/microsoft.compute/virtualmachines/{}/migratetovirtualmachinescaleset", "2024-11-01"],
]
}

AZ_SUPPORT_NO_WAIT = True

def _handler(self, command_args):
super()._handler(command_args)
return self.build_lro_poller(self._execute_operations, None)

_args_schema = None

@classmethod
def _build_arguments_schema(cls, *args, **kwargs):
if cls._args_schema is not None:
return cls._args_schema
cls._args_schema = super()._build_arguments_schema(*args, **kwargs)

# define Arg Group ""

_args_schema = cls._args_schema
_args_schema.resource_group = AAZResourceGroupNameArg(
required=True,
)
_args_schema.vm_name = AAZStrArg(
options=["--vm-name"],
help="The name of the virtual machine.",
required=True,
id_part="name",
)

# define Arg Group "Parameters"

_args_schema = cls._args_schema
_args_schema.target_fault_domain = AAZIntArg(
options=["--target-fault-domain"],
arg_group="Parameters",
help="The target compute fault domain of VM migration to Flexible Virtual Machine Scale Set.",
)
_args_schema.target_vm_size = AAZStrArg(
options=["--target-vm-size"],
arg_group="Parameters",
help="The target Virtual Machine size of VM migration to Flexible Virtual Machine Scale Set.",
)
_args_schema.target_zone = AAZStrArg(
options=["--target-zone"],
arg_group="Parameters",
help="The target zone of VM migration to Flexible Virtual Machine Scale Set.",
)
return cls._args_schema

def _execute_operations(self):
self.pre_operations()
yield self.VirtualMachinesMigrateToVMScaleSet(ctx=self.ctx)()
self.post_operations()

@register_callback
def pre_operations(self):
pass

@register_callback
def post_operations(self):
pass

class VirtualMachinesMigrateToVMScaleSet(AAZHttpOperation):
CLIENT_TYPE = "MgmtClient"

def __call__(self, *args, **kwargs):
request = self.make_request()
session = self.client.send_request(request=request, stream=False, **kwargs)
if session.http_response.status_code in [202]:
return self.client.build_lro_polling(
self.ctx.args.no_wait,
session,
None,
self.on_error,
lro_options={"final-state-via": "location"},
path_format_arguments=self.url_parameters,
)

return self.on_error(session.http_response)

@property
def url(self):
return self.client.format_url(
"/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Compute/virtualMachines/{vmName}/migrateToVirtualMachineScaleSet",
**self.url_parameters
)

@property
def method(self):
return "POST"

@property
def error_format(self):
return "ODataV4Format"

@property
def url_parameters(self):
parameters = {
**self.serialize_url_param(
"resourceGroupName", self.ctx.args.resource_group,
required=True,
),
**self.serialize_url_param(
"subscriptionId", self.ctx.subscription_id,
required=True,
),
**self.serialize_url_param(
"vmName", self.ctx.args.vm_name,
required=True,
),
}
return parameters

@property
def query_parameters(self):
parameters = {
**self.serialize_query_param(
"api-version", "2024-11-01",
required=True,
),
}
return parameters

@property
def header_parameters(self):
parameters = {
**self.serialize_header_param(
"Content-Type", "application/json",
),
}
return parameters

@property
def content(self):
_content_value, _builder = self.new_content_builder(
self.ctx.args,
typ=AAZObjectType,
typ_kwargs={"flags": {"client_flatten": True}}
)
_builder.set_prop("targetFaultDomain", AAZIntType, ".target_fault_domain")
_builder.set_prop("targetVMSize", AAZStrType, ".target_vm_size")
_builder.set_prop("targetZone", AAZStrType, ".target_zone")

return self.serialize_content(_content_value)


class _MigrateToVmssHelper:
"""Helper class for MigrateToVmss"""


__all__ = ["MigrateToVmss"]
Original file line number Diff line number Diff line change
Expand Up @@ -9,8 +9,12 @@
# flake8: noqa

from .__cmd_group import *
from ._cancel_migration_to_vmss import *
from ._convert_to_vmss import *
from ._delete import *
from ._list import *
from ._list_sizes import *
from ._show import *
from ._start_migration_to_vmss import *
from ._update import *
from ._validate_migration_to_vmss import *
Original file line number Diff line number Diff line change
@@ -0,0 +1,133 @@
# --------------------------------------------------------------------------------------------
# Copyright (c) Microsoft Corporation. All rights reserved.
# Licensed under the MIT License. See License.txt in the project root for license information.
#
# Code generated by aaz-dev-tools
# --------------------------------------------------------------------------------------------

# pylint: skip-file
# flake8: noqa

from azure.cli.core.aaz import *


@register_command(
"vm availability-set cancel-migration-to-vmss",
)
class CancelMigrationToVmss(AAZCommand):
"""Cancel the migration operation on an Availability Set.

:example: Cancel migration to vmss
az vm availability-set cancel-migration-to-vmss --resource-group rgcompute --availability-set-name myAvailabilitySet
"""

_aaz_info = {
"version": "2024-11-01",
"resources": [
["mgmt-plane", "/subscriptions/{}/resourcegroups/{}/providers/microsoft.compute/availabilitysets/{}/cancelmigrationtovirtualmachinescaleset", "2024-11-01"],
]
}

def _handler(self, command_args):
super()._handler(command_args)
self._execute_operations()
return None

_args_schema = None

@classmethod
def _build_arguments_schema(cls, *args, **kwargs):
if cls._args_schema is not None:
return cls._args_schema
cls._args_schema = super()._build_arguments_schema(*args, **kwargs)

# define Arg Group ""

_args_schema = cls._args_schema
_args_schema.availability_set_name = AAZStrArg(
options=["-n", "--name", "--availability-set-name"],
help="The name of the availability set.",
required=True,
id_part="name",
)
_args_schema.resource_group = AAZResourceGroupNameArg(
required=True,
)
return cls._args_schema

def _execute_operations(self):
self.pre_operations()
self.AvailabilitySetsCancelMigrationToVirtualMachineScaleSet(ctx=self.ctx)()
self.post_operations()

@register_callback
def pre_operations(self):
pass

@register_callback
def post_operations(self):
pass

class AvailabilitySetsCancelMigrationToVirtualMachineScaleSet(AAZHttpOperation):
CLIENT_TYPE = "MgmtClient"

def __call__(self, *args, **kwargs):
request = self.make_request()
session = self.client.send_request(request=request, stream=False, **kwargs)
if session.http_response.status_code in [204]:
return self.on_204(session)

return self.on_error(session.http_response)

@property
def url(self):
return self.client.format_url(
"/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Compute/availabilitySets/{availabilitySetName}/cancelMigrationToVirtualMachineScaleSet",
**self.url_parameters
)

@property
def method(self):
return "POST"

@property
def error_format(self):
return "ODataV4Format"

@property
def url_parameters(self):
parameters = {
**self.serialize_url_param(
"availabilitySetName", self.ctx.args.availability_set_name,
required=True,
),
**self.serialize_url_param(
"resourceGroupName", self.ctx.args.resource_group,
required=True,
),
**self.serialize_url_param(
"subscriptionId", self.ctx.subscription_id,
required=True,
),
}
return parameters

@property
def query_parameters(self):
parameters = {
**self.serialize_query_param(
"api-version", "2024-11-01",
required=True,
),
}
return parameters

def on_204(self, session):
pass


class _CancelMigrationToVmssHelper:
"""Helper class for CancelMigrationToVmss"""


__all__ = ["CancelMigrationToVmss"]
Loading