|
| 1 | +"""Manage Migrations of Virtual Guests""" |
| 2 | +# :license: MIT, see LICENSE for more details. |
| 3 | +import click |
| 4 | + |
| 5 | +import SoftLayer |
| 6 | +from SoftLayer.CLI import environment |
| 7 | +from SoftLayer.CLI import formatting |
| 8 | +from SoftLayer import utils |
| 9 | + |
| 10 | + |
| 11 | +@click.command() |
| 12 | +@click.option('--guest', '-g', type=click.INT, help="Guest ID to immediately migrate.") |
| 13 | +@click.option('--all', '-a', 'migrate_all', is_flag=True, default=False, |
| 14 | + help="Migrate ALL guests that require migration immediately.") |
| 15 | +@click.option('--host', '-h', type=click.INT, |
| 16 | + help="Dedicated Host ID to migrate to. Only works on guests that are already on a dedicated host.") |
| 17 | +@environment.pass_env |
| 18 | +def cli(env, guest, migrate_all, host): |
| 19 | + """Manage VSIs that require migration. Can migrate Dedicated Host VSIs as well.""" |
| 20 | + |
| 21 | + vsi = SoftLayer.VSManager(env.client) |
| 22 | + pending_filter = {'virtualGuests': {'pendingMigrationFlag': {'operation': 1}}} |
| 23 | + dedicated_filer = {'virtualGuests': {'dedicatedHost': {'id': {'operation': 'not null'}}}} |
| 24 | + mask = """mask[ |
| 25 | + id, hostname, domain, datacenter, pendingMigrationFlag, powerState, |
| 26 | + primaryIpAddress,primaryBackendIpAddress, dedicatedHost |
| 27 | + ]""" |
| 28 | + |
| 29 | + # No options, just print out a list of guests that can be migrated |
| 30 | + if not (guest or migrate_all): |
| 31 | + require_migration = vsi.list_instances(filter=pending_filter, mask=mask) |
| 32 | + require_table = formatting.Table(['id', 'hostname', 'domain', 'datacenter'], title="Require Migration") |
| 33 | + |
| 34 | + for vsi_object in require_migration: |
| 35 | + require_table.add_row([ |
| 36 | + vsi_object.get('id'), |
| 37 | + vsi_object.get('hostname'), |
| 38 | + vsi_object.get('domain'), |
| 39 | + utils.lookup(vsi_object, 'datacenter', 'name') |
| 40 | + ]) |
| 41 | + |
| 42 | + if require_migration: |
| 43 | + env.fout(require_table) |
| 44 | + else: |
| 45 | + click.secho("No guests require migration at this time", fg='green') |
| 46 | + |
| 47 | + migrateable = vsi.list_instances(filter=dedicated_filer, mask=mask) |
| 48 | + migrateable_table = formatting.Table(['id', 'hostname', 'domain', 'datacenter', 'Host Name', 'Host Id'], |
| 49 | + title="Dedicated Guests") |
| 50 | + for vsi_object in migrateable: |
| 51 | + migrateable_table.add_row([ |
| 52 | + vsi_object.get('id'), |
| 53 | + vsi_object.get('hostname'), |
| 54 | + vsi_object.get('domain'), |
| 55 | + utils.lookup(vsi_object, 'datacenter', 'name'), |
| 56 | + utils.lookup(vsi_object, 'dedicatedHost', 'name'), |
| 57 | + utils.lookup(vsi_object, 'dedicatedHost', 'id') |
| 58 | + ]) |
| 59 | + env.fout(migrateable_table) |
| 60 | + # Migrate all guests with pendingMigrationFlag=True |
| 61 | + elif migrate_all: |
| 62 | + require_migration = vsi.list_instances(filter=pending_filter, mask="mask[id]") |
| 63 | + for vsi_object in require_migration: |
| 64 | + migrate(vsi, guest) |
| 65 | + # Just migrate based on the options |
| 66 | + else: |
| 67 | + migrate(vsi, guest, host) |
| 68 | + |
| 69 | + |
| 70 | +def migrate(vsi_manager, vsi_id, host_id=None): |
| 71 | + """Handles actually migrating virtual guests and handling the exception""" |
| 72 | + |
| 73 | + try: |
| 74 | + if host_id: |
| 75 | + vsi_manager.migrate_dedicated(vsi_id, host_id) |
| 76 | + else: |
| 77 | + vsi_manager.migrate(vsi_id) |
| 78 | + click.secho("Started a migration on {}".format(vsi_id), fg='green') |
| 79 | + except SoftLayer.exceptions.SoftLayerAPIError as ex: |
| 80 | + click.secho("Failed to migrate {}. {}".format(vsi_id, str(ex)), fg='red') |
0 commit comments