X-Git-Url: https://code.grnet.gr/git/ganeti-local/blobdiff_plain/a181730e4e262dda65ffa5822231a488a49b6849..dc922da0868e789a8d3322420ccd124460b63db3:/scripts/gnt-backup diff --git a/scripts/gnt-backup b/scripts/gnt-backup index dce8ecd..467b37d 100755 --- a/scripts/gnt-backup +++ b/scripts/gnt-backup @@ -19,43 +19,55 @@ # 02110-1301, USA. +# pylint: disable-msg=W0401,W0614 +# W0401: Wildcard import ganeti.cli +# W0614: Unused import %s from wildcard import (since we need cli) + import sys from optparse import make_option from ganeti.cli import * -from ganeti import cmdlib from ganeti import opcodes from ganeti import constants +from ganeti import errors +from ganeti import utils + + +_VALUE_TRUE = "true" def PrintExportList(opts, args): """Prints a list of all the exported system images. - Args: - opts - class with options as members (should be empty) - args - should be empty - - Returns: - nothing + @param opts: the command line options selected by the user + @type args: list + @param args: should be an empty list + @rtype: int + @return: the desired exit code """ - op = opcodes.OpQueryExports(nodes=opts.nodes) - exports = SubmitOpCode(op) + exports = GetClient().QueryExports(opts.nodes, False) + retcode = 0 for node in exports: - print ("Node: %s" % node) - print ("Exports:") - for instance_name in exports[node]: - print ("\t%s" % instance_name) + ToStdout("Node: %s", node) + ToStdout("Exports:") + if isinstance(exports[node], list): + for instance_name in exports[node]: + ToStdout("\t%s", instance_name) + else: + ToStdout(" Could not get exports list") + retcode = 1 + return retcode def ExportInstance(opts, args): """Export an instance to an image in the cluster. - Args: - opts - class with options as members - args - list with a single element, the instance name - - Returns: - 1 in case of error, 0 otherwise + @param opts: the command line options selected by the user + @type args: list + @param args: should contain only one element, the name + of the instance to be exported + @rtype: int + @return: the desired exit code """ op = opcodes.OpExportInstance(instance_name=args[0], @@ -64,69 +76,141 @@ def ExportInstance(opts, args): SubmitOpCode(op) + def ImportInstance(opts, args): """Add an instance to the cluster. - Args: - opts - class with options as members - args - list with a single element, the new instance name - Opts used: - memory - amount of memory to allocate to instance (MiB) - size - amount of disk space to allocate to instance (MiB) - os - which OS to run on instance - node - node to run new instance on - src_node - node containing the export - src_dir - directory on the old node with the export in it - - Returns: - 1 in case of error, 0 otherwise + @param opts: the command line options selected by the user + @type args: list + @param args: should contain only one element, the new instance name + @rtype: int + @return: the desired exit code """ instance = args[0] - op = opcodes.OpCreateInstance(instance_name=instance, mem_size=opts.mem, - disk_size=opts.size, swap_size=opts.swap, + (pnode, snode) = SplitNodeOption(opts.node) + + hypervisor = None + hvparams = {} + if opts.hypervisor: + hypervisor, hvparams = opts.hypervisor + + if opts.nics: + try: + nic_max = max(int(nidx[0])+1 for nidx in opts.nics) + except ValueError, err: + raise errors.OpPrereqError("Invalid NIC index passed: %s" % str(err)) + nics = [{}] * nic_max + for nidx, ndict in opts.nics: + nidx = int(nidx) + nics[nidx] = ndict + elif opts.no_nics: + # no nics + nics = [] + else: + # default of one nic, all auto + nics = [{}] + + if opts.disk_template == constants.DT_DISKLESS: + if opts.disks or opts.sd_size is not None: + raise errors.OpPrereqError("Diskless instance but disk" + " information passed") + disks = [] + else: + if not opts.disks and not opts.sd_size: + raise errors.OpPrereqError("No disk information specified") + if opts.disks and opts.sd_size is not None: + raise errors.OpPrereqError("Please use either the '--disk' or" + " '-s' option") + if opts.sd_size is not None: + opts.disks = [(0, {"size": opts.sd_size})] + try: + disk_max = max(int(didx[0])+1 for didx in opts.disks) + except ValueError, err: + raise errors.OpPrereqError("Invalid disk index passed: %s" % str(err)) + disks = [{}] * disk_max + for didx, ddict in opts.disks: + didx = int(didx) + if "size" not in ddict: + raise errors.OpPrereqError("Missing size for disk %d" % didx) + try: + ddict["size"] = utils.ParseUnit(ddict["size"]) + except ValueError, err: + raise errors.OpPrereqError("Invalid disk size for disk %d: %s" % + (didx, err)) + disks[didx] = ddict + + utils.ForceDictType(opts.beparams, constants.BES_PARAMETER_TYPES) + utils.ForceDictType(hvparams, constants.HVS_PARAMETER_TYPES) + + op = opcodes.OpCreateInstance(instance_name=instance, disk_template=opts.disk_template, + disks=disks, + nics=nics, mode=constants.INSTANCE_IMPORT, - pnode=opts.node, snode=opts.snode, - vcpus=opts.vcpus, ip_check=opts.ip_check, - ip=opts.ip, bridge=opts.bridge, start=False, + pnode=pnode, snode=snode, + ip_check=opts.ip_check, + start=False, src_node=opts.src_node, src_path=opts.src_dir, - wait_for_sync=opts.wait_for_sync) + wait_for_sync=opts.wait_for_sync, + file_storage_dir=opts.file_storage_dir, + file_driver=opts.file_driver, + iallocator=opts.iallocator, + hypervisor=hypervisor, + hvparams=hvparams, + beparams=opts.beparams) + SubmitOpCode(op) return 0 -# options used in more than one cmd -node_opt = make_option("-n", "--node", dest="node", help="Target node", - metavar="") +def RemoveExport(opts, args): + """Remove an export from the cluster. + + @param opts: the command line options selected by the user + @type args: list + @param args: should contain only one element, the name of the + instance whose backup should be removed + @rtype: int + @return: the desired exit code + + """ + instance = args[0] + op = opcodes.OpRemoveExport(instance_name=args[0]) + + SubmitOpCode(op) + return 0 + # this is defined separately due to readability only import_opts = [ DEBUG_OPT, - node_opt, - cli_option("-s", "--os-size", dest="size", help="Disk size", - default=20 * 1024, type="unit", metavar=""), - cli_option("--swap-size", dest="swap", help="Swap size", - default=4 * 1024, type="unit", metavar=""), - cli_option("-m", "--memory", dest="mem", help="Memory size", - default=128, type="unit", metavar=""), - make_option("-p", "--cpu", dest="vcpus", help="Number of virtual CPUs", - default=1, type="int", metavar=""), + make_option("-n", "--node", dest="node", + help="Target node and optional secondary node", + metavar="[:]"), + keyval_option("-B", "--backend", dest="beparams", + type="keyval", default={}, + help="Backend parameters"), make_option("-t", "--disk-template", dest="disk_template", - help="Custom disk setup (diskless, plain, local_raid1 or" - " remote_raid1)", default=None, metavar="TEMPL"), - make_option("-i", "--ip", dest="ip", - help="IP address ('none' [default], 'auto', or specify address)", - default='none', type="string", metavar="
"), + help="Custom disk setup (diskless, file, plain, drbd)", + default=None, metavar="TEMPL"), + ikv_option("--disk", help="Disk information", + default=[], dest="disks", + action="append", + type="identkeyval"), + cli_option("-s", "--os-size", dest="sd_size", help="Disk size for a" + " single-disk configuration, when not using the --disk option," + " in MiB unless a suffix is used", + default=None, type="unit", metavar=""), + ikv_option("--net", help="NIC information", + default=[], dest="nics", + action="append", + type="identkeyval"), + make_option("--no-nics", default=False, action="store_true", + help="Do not create any network cards for the instance"), make_option("--no-wait-for-sync", dest="wait_for_sync", default=True, action="store_false", help="Don't wait for sync (DANGEROUS!)"), - make_option("--secondary-node", dest="snode", - help="Secondary node for remote_raid1 disk layout", - metavar=""), - make_option("-b", "--bridge", dest="bridge", - help="Bridge to connect this instance to", - default=None, metavar=""), make_option("--src-node", dest="src_node", help="Source node", metavar=""), make_option("--src-dir", dest="src_dir", help="Source directory", @@ -134,24 +218,46 @@ import_opts = [ make_option("--no-ip-check", dest="ip_check", default=True, action="store_false", help="Don't check that the instance's IP" " is alive"), + make_option("-I", "--iallocator", metavar="", + help="Select nodes for the instance automatically using the" + " iallocator plugin", default=None, type="string"), + make_option("--file-storage-dir", dest="file_storage_dir", + help="Relative path under default cluster-wide file storage dir" + " to store file-based disks", default=None, + metavar=""), + make_option("--file-driver", dest="file_driver", help="Driver to use" + " for image files", default="loop", metavar=""), + ikv_option("-H", "--hypervisor", dest="hypervisor", + help="Hypervisor and hypervisor options, in the format" + " hypervisor:option=value,option=value,...", default=None, + type="identkeyval"), ] commands = { 'list': (PrintExportList, ARGS_NONE, [DEBUG_OPT, - make_option("--nodes", dest="nodes", default=[], action="append", - help="List only backups stored on these nodes"), + make_option("--node", dest="nodes", default=[], action="append", + help="List only backups stored on this node" + " (can be used multiple times)"), ], "", "Lists instance exports available in the ganeti cluster"), 'export': (ExportInstance, ARGS_ONE, - [node_opt, DEBUG_OPT, FORCE_OPT, + [DEBUG_OPT, FORCE_OPT, + make_option("-n", "--node", dest="node", help="Target node", + metavar=""), make_option("","--noshutdown", dest="shutdown", action="store_false", default=True, help="Don't shutdown the instance (unsafe)"), ], - "[opts...] ", + "-n [opts...] ", "Exports an instance to an image"), - 'import': (ImportInstance, ARGS_ONE, import_opts, "[opts...] ", + 'import': (ImportInstance, ARGS_ONE, import_opts, + ("[...] -t disk-type -n node[:secondary-node]" + " "), "Imports an instance from an exported image"), + 'remove': (RemoveExport, ARGS_ONE, + [DEBUG_OPT], + "", + "Remove exports of named instance from the filesystem."), } if __name__ == '__main__':