migrate.py

import sys, time
from ZenPacks.community.CiscoEntityEnvMon.CiscoDevice import CiscoDevice
sys.stdout = os.fdopen(sys.stdout.fileno(), 'w', 0)

CHUNK_SIZE = 100
ORGANIZERS = [
    dmd.Devices.Network.Switch.Cisco,
    dmd.Devices.Network.Router.Cisco, ]

def chunks(bulk, chunk_size):
    for i in range(0, len(bulk), chunk_size):
        yield bulk[i:i+chunk_size]

def update_class(organizer):
    print "migrate devices in %s" % organizer.getOrganizerName()

    devices = filter(lambda x: not isinstance(x, CiscoDevice),
                     organizer.getSubDevices())

    if not devices: return

    for chunk in chunks(devices, CHUNK_SIZE):
        sys.stdout.write('.')
        organizer.moveDevices(
            organizer.getOrganizerName(),
            map(lambda x: x.id, chunk))
        commit()

        print "\n%i devices successfully migrated" % len(devices)

    return devices

map(lambda x: update_class(x), ORGANIZERS)

if filter(lambda x: isinstance(x, CiscoDevice),
          reduce(lambda x, y: x+y, map(lambda x: x.getSubDevices(), ORGANIZERS))):
    print "\nall devices were successfully migrated"
else:
    print "\nsome devices were not migrated, inspection needed"