本文整理汇总了Python中pysilhouette.command.dict2command函数的典型用法代码示例。如果您正苦于以下问题:Python dict2command函数的具体用法?Python dict2command怎么用?Python dict2command使用的例子?那么恭喜您, 这里精选的函数代码示例或许可以为您提供帮助。
在下文中一共展示了dict2command函数的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Python代码示例。
示例1: create_pool_dir_job
def create_pool_dir_job(obj, machine, name, type_, target_path, options={}, rollback_options={}):
cmdname = u"Create Storage Pool"
cmd = VIRT_COMMAND_CREATE_STORAGE_POOL
options["name"] = name
options["type"] = type_
options["target_path"] = target_path
options["mode"] = STORAGE_POOL_PWD["MODE"]
options["group"] = pwd.getpwnam(STORAGE_POOL_PWD["GROUP"])[2]
options["owner"] = pwd.getpwnam(STORAGE_POOL_PWD["OWNER"])[2]
_cmd = dict2command("%s/%s" % (karesansui.config["application.bin.dir"], cmd), options)
rollback_options["name"] = name
rollback_cmd = dict2command(
"%s/%s" % (karesansui.config["application.bin.dir"], VIRT_COMMAND_DELETE_STORAGE_POOL), rollback_options
)
_jobgroup = JobGroup(cmdname, karesansui.sheconf["env.uniqkey"])
_job = Job("%s command" % cmdname, 0, _cmd)
_job.rollback_command = rollback_cmd
_jobgroup.jobs.append(_job)
_machine2jobgroup = m2j_new(
machine=machine,
jobgroup_id=-1,
uniq_key=karesansui.sheconf["env.uniqkey"],
created_user=obj.me,
modified_user=obj.me,
)
save_job_collaboration(obj.orm, obj.pysilhouette.orm, _machine2jobgroup, _jobgroup)
return True
开发者ID:nabeken,项目名称:karesansui,代码行数:35,代码来源:hostby1storagepool.py
示例2: make_storage_volume_job
def make_storage_volume_job(uuid, name, pool_name, format,
capacity, allocation, unit, order):
cmdname = u"Create Storage Volume"
cmd = VIRT_COMMAND_CREATE_STORAGE_VOLUME
options = {}
options['volume_name'] = uuid
options['name'] = name
options['pool_name'] = pool_name
options['format'] = format
options['capacity'] = capacity
options['allocation'] = allocation
options['unit'] = unit
options['permission_owner'] = pwd.getpwnam(STORAGE_VOLUME_PWD["OWNER"])[2]
options['permission_group'] = pwd.getpwnam(STORAGE_VOLUME_PWD["GROUP"])[2]
options['permission_mode'] = STORAGE_VOLUME_PWD["MODE"]
options['use'] = DISK_USES["IMAGES"]
_cmd = dict2command(
"%s/%s" % (karesansui.config['application.bin.dir'], cmd), options)
rollback_options = {}
#rollback_options["name"] = name
rollback_options["name"] = uuid
rollback_options["pool_name"] = pool_name
rollback_options["use"] = DISK_USES["IMAGES"]
rollback_cmd = dict2command(
"%s/%s" % (karesansui.config['application.bin.dir'], VIRT_COMMAND_DELETE_STORAGE_VOLUME),
rollback_options)
_job = Job('%s command' % cmdname, order, _cmd)
# delete_guestコマンドが削除まで担当してくれるので、ここではロールバックコマンドを設定しない。
#_job.rollback_command = rollback_cmd
return _job
开发者ID:fkei,项目名称:karesansui,代码行数:35,代码来源:guest.py
示例3: network_start_stop_job
def network_start_stop_job(obj, host_id, network_name, action):
"""
Register start/stop network job into pysilhouette
@param obj: Rest object
@param network_name: Name of network to start or stop
@type network_name: string
@param action: 'start' or 'stop'
@type action: string
"""
if not network_name:
raise KaresansuiException
if (karesansui.sheconf.has_key('env.uniqkey') is False) \
or (karesansui.sheconf['env.uniqkey'].strip('') == ''):
raise KaresansuiException
if not (action == 'start' or action == 'stop'):
raise KaresansuiException
host = findbyhost1(obj.orm, host_id)
_cmd = None
_jobgroup = None
if action == 'start':
cmdname = ["Start Network", "start network"]
_cmd = dict2command(
"%s/%s" % (karesansui.config['application.bin.dir'], 'restart_network.py'),
dict(name=network_name, force=None))
else:
cmdname = ["Stop Network", "stop network"]
_cmd = dict2command(
"%s/%s" % (karesansui.config['application.bin.dir'], 'stop_network.py'),
dict(name=network_name))
# Job Register
_jobgroup = JobGroup(cmdname[0], karesansui.sheconf['env.uniqkey'])
_jobgroup.jobs.append(Job('%s command' % cmdname[1], 0, _cmd))
_machine2jobgroup = m2j_new(machine=host,
jobgroup_id=-1,
uniq_key=karesansui.sheconf['env.uniqkey'],
created_user=obj.me,
modified_user=obj.me,
)
# INSERT
save_job_collaboration(obj.orm,
obj.pysilhouette.orm,
_machine2jobgroup,
_jobgroup,
)
开发者ID:AdUser,项目名称:karesansui,代码行数:52,代码来源:hostby1networkby1status.py
示例4: iptables_control
def iptables_control(obj, model, action='',options={}):
if action != "":
options['action'] = action
if action == "restart":
action_msg = "Restart iptables"
elif action == "start":
action_msg = "Start iptables"
msg = "Start iptables"
elif action == "stop":
action_msg = "Stop iptables"
_cmd = dict2command(
"%s/%s" % (karesansui.config['application.bin.dir'], IPTABLES_COMMAND_CONTROL), options)
_jobgroup = JobGroup(action_msg, karesansui.sheconf['env.uniqkey'])
_jobgroup.jobs.append(Job("%s command" % action_msg, 0, _cmd))
_machine2jobgroup = m2j_new(machine=model,
jobgroup_id=-1,
uniq_key=karesansui.sheconf['env.uniqkey'],
created_user=obj.me,
modified_user=obj.me,
)
save_job_collaboration(obj.orm,
obj.pysilhouette.orm,
_machine2jobgroup,
_jobgroup,
)
return True
开发者ID:goura,项目名称:karesansui,代码行数:32,代码来源:hostby1iptablesstatus.py
示例5: firewall_restore
def firewall_restore(obj, model, action='',options={}):
if action != "":
options['action'] = action
if action == "restart":
action_msg = "Restart firewall"
elif action == "start":
action_msg = "Start firewall"
msg = "Start firewall"
elif action == "stop":
action_msg = "Stop firewall"
else:
action_msg = "Restore firewall"
_cmd = dict2command(
"%s/%s" % (karesansui.config['application.bin.dir'], FIREWALL_COMMAND_RESTORE_FIREWALL), options)
_jobgroup = JobGroup(action_msg, karesansui.sheconf['env.uniqkey'])
_jobgroup.jobs.append(Job("%s command" % action_msg, 0, _cmd))
_machine2jobgroup = m2j_new(machine=model,
jobgroup_id=-1,
uniq_key=karesansui.sheconf['env.uniqkey'],
created_user=obj.me,
modified_user=obj.me,
)
save_job_collaboration(obj.orm,
obj.pysilhouette.orm,
_machine2jobgroup,
_jobgroup,
)
return True
开发者ID:goura,项目名称:karesansui,代码行数:34,代码来源:hostby1firewallstatus.py
示例6: create_nic_job
def create_nic_job(obj, guest, name, mac, bridge, network, options={}):
options['name'] = name
options['mac'] = mac
if bridge is not None:
options['bridge'] = bridge
if network is not None:
options['network'] = network
_cmd = dict2command(
"%s/%s" % (karesansui.config['application.bin.dir'], VIRT_COMMAND_ADD_NIC), options)
cmdname = u"Create NIC"
_jobgroup = JobGroup(cmdname, karesansui.sheconf['env.uniqkey'])
_jobgroup.jobs.append(Job('%s command' % cmdname, 0, _cmd))
_machine2jobgroup = m2j_new(machine=guest,
jobgroup_id=-1,
uniq_key=karesansui.sheconf['env.uniqkey'],
created_user=obj.me,
modified_user=obj.me,
)
save_job_collaboration(obj.orm,
obj.pysilhouette.orm,
_machine2jobgroup,
_jobgroup,
)
开发者ID:goura,项目名称:karesansui,代码行数:27,代码来源:guestby1nic.py
示例7: replicate_guest
def replicate_guest(obj, guest, cmd, options, cmdname, rollback_options, order):
if (karesansui.sheconf.has_key('env.uniqkey') is False) \
or (karesansui.sheconf['env.uniqkey'].strip('') == ''):
raise
action_cmd = dict2command(
"%s/%s" % (karesansui.config['application.bin.dir'], cmd),
options)
rollback_cmd = dict2command(
"%s/%s" % (karesansui.config['application.bin.dir'], VIRT_COMMAND_DELETE_GUEST),
rollback_options)
job = Job(cmdname, order, action_cmd)
job.rollback_command = rollback_cmd
return job
开发者ID:goura,项目名称:karesansui,代码行数:16,代码来源:guestreplicate.py
示例8: _DELETE
def _DELETE(self, *param, **params):
host_id = self.chk_hostby1(param)
if host_id is None: return web.notfound()
device = param[1]
if device is None: return web.notfound()
cmdname = u"Delete Bonding Setting"
cmd = BONDING_COMMAND_DELETE
options = {}
options['dev'] = device
options["succession"] = None
_cmd = dict2command(
"%s/%s" % (karesansui.config['application.bin.dir'], cmd), options)
_jobgroup = JobGroup(cmdname, karesansui.sheconf['env.uniqkey'])
_job = Job('%s command' % cmdname, 0, _cmd)
_jobgroup.jobs.append(_job)
host = findbyhost1(self.orm, host_id)
_machine2jobgroup = m2j_new(machine=host,
jobgroup_id=-1,
uniq_key=karesansui.sheconf['env.uniqkey'],
created_user=self.me,
modified_user=self.me,
)
save_job_collaboration(self.orm,
self.pysilhouette.orm,
_machine2jobgroup,
_jobgroup,
)
return web.accepted()
开发者ID:AdUser,项目名称:karesansui,代码行数:35,代码来源:hostby1networksettingsnicby1.py
示例9: change_mac_job
def change_mac_job(obj, guest, name, old_mac, new_mac, options={}):
options['name'] = name
options['from'] = old_mac
options['to'] = new_mac
_cmd = dict2command(
"%s/%s" % (karesansui.config['application.bin.dir'], VIRT_COMMAND_SET_MAC_ADDRESS), options)
cmdname = u"Change MAC Address"
_jobgroup = JobGroup(cmdname, karesansui.sheconf['env.uniqkey'])
_jobgroup.jobs.append(Job("%s command" % cmdname, 0, _cmd))
_machine2jobgroup = m2j_new(machine=guest,
jobgroup_id=-1,
uniq_key=karesansui.sheconf['env.uniqkey'],
created_user=obj.me,
modified_user=obj.me,
)
save_job_collaboration(obj.orm,
obj.pysilhouette.orm,
_machine2jobgroup,
_jobgroup,
)
return True
开发者ID:AdUser,项目名称:karesansui,代码行数:26,代码来源:guestby1nicby1.py
示例10: create_disk_job
def create_disk_job(obj, guest, domain_name, pool, volume,
bus, format, type, target=None, order=0):
"""<comment-ja>
ディスク追加ジョブを作成します。
</comment-ja>
<comment-en>
TODO: To include comments in English
</comment-en>
"""
cmdname = u"Add Disk"
cmd = VIRT_COMMAND_ADD_DISK
options = {}
options['name'] = domain_name
options['pool'] = pool
options['volume'] = volume
options['bus'] = bus
options['type'] = type
if target is not None:
options['target'] = target
if type != 'iscsi':
options['format'] = format
_cmd = dict2command(
"%s/%s" % (karesansui.config['application.bin.dir'], cmd), options)
job = Job('%s command' % cmdname, order, _cmd)
return job
开发者ID:AdUser,项目名称:karesansui,代码行数:29,代码来源:guestby1disk.py
示例11: _PUT
def _PUT(self, *param, **params):
"""<comment-ja>
Japanese Comment
</comment-ja>
<comment-en>
TODO: English Comment
</comment-en>
"""
(host_id, guest_id) = self.chk_guestby1(param)
if guest_id is None:
return web.notfound()
if is_param(self.input, "memory"):
memory = int(self.input.memory)
else:
memory = None
max_memory = int(self.input.max_memory)
model = findbyguest1(self.orm, guest_id)
# virt
kvc = KaresansuiVirtConnection()
try:
domname = kvc.uuid_to_domname(model.uniq_key)
if not domname:
return web.conflict(web.ctx.path)
virt = kvc.search_kvg_guests(domname)[0]
info = virt.get_info()
# maxMem = info["maxMem"]
now_memory = info["memory"]
mem_info = kvc.get_mem_info()
nodeinfo = kvc.get_nodeinfo()
finally:
kvc.close()
# valid
# if (mem_info["host_free_mem"] + (now_memory / 1024)) < memory:
# return web.badrequest("Memory value is greater than the maximum memory value. - memory=%s" % self.input.memory)
options = {}
options["name"] = domname
options["maxmem"] = max_memory
if memory is None:
options["memory"] = max_memory
else:
options["memory"] = memory
_cmd = dict2command("%s/%s" % (karesansui.config["application.bin.dir"], VIRT_COMMAND_SET_MEMORY), options)
cmdname = "Set memory"
_jobgroup = JobGroup(cmdname, karesansui.sheconf["env.uniqkey"])
_jobgroup.jobs.append(Job("%s command" % cmdname, 0, _cmd))
_machine2jobgroup = m2j_new(
machine=model,
jobgroup_id=-1,
uniq_key=karesansui.sheconf["env.uniqkey"],
created_user=self.me,
modified_user=self.me,
)
save_job_collaboration(self.orm, self.pysilhouette.orm, _machine2jobgroup, _jobgroup)
return web.accepted(url=web.ctx.path)
开发者ID:goura,项目名称:karesansui,代码行数:59,代码来源:guestby1memory.py
示例12: service_job
def service_job(obj, host, name, status):
if status == 'start':
_cmd = dict2command(
"%s/%s" % (karesansui.config['application.bin.dir'], SERVICE_COMMAND_START),
{"name" : name})
cmdname = "Start Service"
elif status == 'stop':
_cmd = dict2command(
"%s/%s" % (karesansui.config['application.bin.dir'], SERVICE_COMMAND_STOP),
{"name" : name})
cmdname = "Stop Service"
elif status == 'restart':
_cmd = dict2command(
"%s/%s" % (karesansui.config['application.bin.dir'], SERVICE_COMMAND_RESTART),
{"name" : name})
cmdname = "Restart Service"
elif status == 'enable':
_cmd = dict2command(
"%s/%s" % (karesansui.config['application.bin.dir'], SERVICE_COMMAND_AUTOSTART),
{"name" : name, "enable": None})
cmdname = "Enable Autostart Service"
elif status == 'disable':
_cmd = dict2command(
"%s/%s" % (karesansui.config['application.bin.dir'], SERVICE_COMMAND_AUTOSTART),
{"name" : name, "disable": None})
cmdname = "Disable Autostart Service"
else:
raise
_jobgroup = JobGroup(cmdname, karesansui.sheconf['env.uniqkey'])
_job = Job(cmdname, 0, _cmd)
_jobgroup.jobs.append(_job)
_machine2jobgroup = m2j_new(machine=host,
jobgroup_id=-1,
uniq_key=karesansui.sheconf['env.uniqkey'],
created_user=obj.me,
modified_user=obj.me,
)
save_job_collaboration(obj.orm,
obj.pysilhouette.orm,
_machine2jobgroup,
_jobgroup,
)
开发者ID:AdUser,项目名称:karesansui,代码行数:46,代码来源:hostby1serviceby1status.py
示例13: delete_disk_job
def delete_disk_job(obj, name, target, order, options={}):
options['name'] = name
options['target'] = target
cmd = dict2command(
"%s/%s" % (karesansui.config['application.bin.dir'], VIRT_COMMAND_DELETE_DISK), options)
job = Job('Delete disk', order, cmd)
return job
开发者ID:goura,项目名称:karesansui,代码行数:9,代码来源:guestby1diskby1.py
示例14: storagepool_start_stop_job
def storagepool_start_stop_job(obj, host, pool_obj, status):
_iscsi_job = None
if status == 'start':
pool_info = pool_obj.get_info()
if pool_info['type'].lower() == "iscsi":
_cmd = dict2command(
"%s/%s" % (karesansui.config['application.bin.dir'], ISCSI_COMMAND_START),
{"iqn" : pool_info['source']['dev_path']})
cmdname = "Start iSCSI"
_iscsi_job = Job('%s command' % cmdname, 0, _cmd)
_cmd = dict2command(
"%s/%s" % (karesansui.config['application.bin.dir'], VIRT_COMMAND_START_STORAGE_POOL),
{"name" : pool_obj.get_storage_name()})
cmdname = "Start Storage Pool"
else:
_cmd = dict2command(
"%s/%s" % (karesansui.config['application.bin.dir'], VIRT_COMMAND_DESTROY_STORAGE_POOL),
{"name" : pool_obj.get_storage_name()})
cmdname = "Stop Storage Pool"
_jobgroup = JobGroup(cmdname, karesansui.sheconf['env.uniqkey'])
if _iscsi_job:
_jobgroup.jobs.append(_iscsi_job)
_job = Job('%s command' % cmdname, 1, _cmd)
else:
_job = Job('%s command' % cmdname, 0, _cmd)
_jobgroup.jobs.append(_job)
_machine2jobgroup = m2j_new(machine=host,
jobgroup_id=-1,
uniq_key=karesansui.sheconf['env.uniqkey'],
created_user=obj.me,
modified_user=obj.me,
)
save_job_collaboration(obj.orm,
obj.pysilhouette.orm,
_machine2jobgroup,
_jobgroup,
)
开发者ID:goura,项目名称:karesansui,代码行数:44,代码来源:hostby1storagepoolby1status.py
示例15: create_storage_volume_dir
def create_storage_volume_dir(obj, guest, domname, volume_name, pool_name, format,
capacity, allocation, unit, order):
"""<comment-ja>
dir形式のストレージボリュームを利用して、ディスク追加を行います。
</comment-ja>
<comment-en>
TODO: To include comments in English
</comment-en>
"""
# create volume
cmdname = u"Create Storage Volume"
cmd = VIRT_COMMAND_CREATE_STORAGE_VOLUME
options = {}
options['name'] = domname
options['pool_name'] = pool_name
options['format'] = format
options['capacity'] = capacity
options['allocation'] = allocation
options['unit'] = unit
options['permission_owner'] = pwd.getpwnam(STORAGE_VOLUME_PWD["OWNER"])[2]
options['permission_group'] = pwd.getpwnam(STORAGE_VOLUME_PWD["GROUP"])[2]
options['permission_mode'] = STORAGE_VOLUME_PWD["MODE"]
options['use'] = DISK_USES["DISK"]
options['volume'] = volume_name
_cmd = dict2command(
"%s/%s" % (karesansui.config['application.bin.dir'], cmd), options)
rollback_options = {}
rollback_options["name"] = domname
rollback_options["pool_name"] = pool_name
rollback_options["use"] = DISK_USES["IMAGES"]
rollback_cmd = dict2command(
"%s/%s" % (karesansui.config['application.bin.dir'],
VIRT_COMMAND_DELETE_STORAGE_VOLUME),
rollback_options)
_job = Job('%s command' % cmdname, order, _cmd)
_job.rollback_command = rollback_cmd
return _job
开发者ID:AdUser,项目名称:karesansui,代码行数:43,代码来源:guestby1disk.py
示例16: _POST
def _POST(self, *param, **params):
(host_id, guest_id) = self.chk_guestby1(param)
if guest_id is None: return web.notfound()
if not validates_snapshot(self):
return web.badrequest(self.view.alert)
guest = findbyguest1(self.orm, guest_id)
kvs = KaresansuiVirtSnapshot(readonly=False)
try:
domname = kvs.kvc.uuid_to_domname(guest.uniq_key)
if not domname: return web.conflict(web.ctx.path)
virt = kvs.kvc.search_kvg_guests(domname)[0]
if virt.is_active() is True:
return web.badrequest(_("Guest is running. Please stop and try again. name=%s" % domname))
finally:
kvs.finish()
id = int(time.time())
notebook = new_notebook(self.input.title, self.input.value)
snapshot = new_snapshot(guest, id, self.me, self.me, notebook)
save_snapshot(self.orm, snapshot)
options = {}
options['name'] = domname
options['id'] = id
_cmd = dict2command(
"%s/%s" % (karesansui.config['application.bin.dir'], VIRT_COMMAND_TAKE_SNAPSHOT),
options)
cmdname = 'Take Snapshot'
_jobgroup = JobGroup(cmdname, karesansui.sheconf['env.uniqkey'])
_jobgroup.jobs.append(Job('%s command' % cmdname, 0, _cmd))
_machine2jobgroup = m2j_new(machine=guest,
jobgroup_id=-1,
uniq_key=karesansui.sheconf['env.uniqkey'],
created_user=self.me,
modified_user=self.me,
)
save_job_collaboration(self.orm,
self.pysilhouette.orm,
_machine2jobgroup,
_jobgroup,
)
return web.accepted()
开发者ID:AdUser,项目名称:karesansui,代码行数:52,代码来源:guestby1snapshot.py
示例17: replicate_storage_volume
def replicate_storage_volume(obj, orig_name, orig_pool, orig_volume,
dest_name, dest_pool, dest_volume,
order):
"""
<comment-ja>
ゲストOSに登録されているディスク(ストレージボリューム)のコピージョブを作成します。
</comment-ja>
<comment-en>
TODO: English Documents(en)
</comment-en>
"""
cmdname = u"Replicate Storage_Volume %s" % dest_name
cmd = VIRT_COMMAND_REPLICATE_STORAGE_VOLUME
options = {}
options["orig_name"] = orig_name
options["orig_pool"] = orig_pool
options["orig_volume"] = orig_volume
options["dest_name"] = dest_name
options["dest_pool"] = dest_pool
options["dest_volume"] = dest_volume
_cmd = dict2command(
"%s/%s" % (karesansui.config['application.bin.dir'], cmd), options)
rollback_options = {}
rollback_options["name"] = dest_volume
rollback_options["pool_name"] = dest_pool
rollback_options["use"] = DISK_USES["DISK"]
rollback_cmd = dict2command(
"%s/%s" % (karesansui.config['application.bin.dir'], VIRT_COMMAND_DELETE_STORAGE_VOLUME),
rollback_options)
job = Job('%s command' % cmdname, order, _cmd)
job.rollback_command = rollback_cmd
return job
开发者ID:goura,项目名称:karesansui,代码行数:39,代码来源:guestreplicate.py
示例18: _POST
def _POST(self, *param, **params):
host_id = self.chk_hostby1(param)
if host_id is None: return web.notfound()
target_regex = re.compile(r"^bonding_target_dev_select_(?P<dev>eth[0-9]+)")
if not validates_bonding(self, target_regex):
self.logger.debug("Add bonding failed. Did not validate.")
return web.badrequest(self.view.alert)
target_dev = []
for input in self.input:
m = target_regex.match(input)
if m:
target_dev.append(m.group('dev'))
primary = self.input.bonding_target_dev_primary
mode = self.input.bonding_mode
cmdname = u"Add Bonding Setting"
cmd = BONDING_COMMAND_ADD
options = {}
options['dev'] = ','.join(target_dev)
options["primary"] = primary
options["mode"] = mode
_cmd = dict2command(
"%s/%s" % (karesansui.config['application.bin.dir'], cmd), options)
_jobgroup = JobGroup(cmdname, karesansui.sheconf['env.uniqkey'])
_job = Job('%s command' % cmdname, 0, _cmd)
_jobgroup.jobs.append(_job)
host = findbyhost1(self.orm, host_id)
_machine2jobgroup = m2j_new(machine=host,
jobgroup_id=-1,
uniq_key=karesansui.sheconf['env.uniqkey'],
created_user=self.me,
modified_user=self.me,
)
save_job_collaboration(self.orm,
self.pysilhouette.orm,
_machine2jobgroup,
_jobgroup,
)
return web.accepted()
开发者ID:goura,项目名称:karesansui,代码行数:49,代码来源:hostby1networksettings.py
示例19: delete_storage_volume
def delete_storage_volume(obj, volume, pool, order, use=DISK_USES["DISK"]):
cmdname = u"Delete Storage Volume"
cmd = VIRT_COMMAND_DELETE_STORAGE_VOLUME
options = {}
options['name'] = volume
options['pool'] = pool
options['use'] = use
_cmd = dict2command(
"%s/%s" % (karesansui.config['application.bin.dir'], cmd), options)
job = Job('%s command' % cmdname, order, _cmd)
return job
开发者ID:goura,项目名称:karesansui,代码行数:15,代码来源:guestby1diskby1.py
示例20: _DELETE
def _DELETE(self, *param, **params):
host_id = self.chk_hostby1(param)
if host_id is None: return web.notfound()
network_name = param[1]
if not network_name:
self.logger.debug("Network delete failed. Network not found.")
return web.notfound("Network not found.")
if network_name == 'default':
self.logger.debug('Network delete failed. Target network is "default".')
return web.badrequest('Target network "default" can not deleted.')
host = findbyhost1(self.orm, host_id)
options = {}
options['name'] = network_name
_cmd = dict2command(
"%s/%s" % (karesansui.config['application.bin.dir'], VIRT_COMMAND_DELETE_NETWORK), options)
# Job Registration
_jobgroup = JobGroup('Delete network: %s' % network_name, karesansui.sheconf['env.uniqkey'])
_jobgroup.jobs.append(Job('Delete network', 0, _cmd))
_machine2jobgroup = m2j_new(machine=host,
jobgroup_id=-1,
uniq_key=karesansui.sheconf['env.uniqkey'],
created_user=self.me,
modified_user=self.me,
)
save_job_collaboration(self.orm,
self.pysilhouette.orm,
_machine2jobgroup,
_jobgroup,
)
self.logger.debug('(Delete network) Job group id==%s', _jobgroup.id)
url = '%s/job/%s.part' % (web.ctx.home, _jobgroup.id)
self.logger.debug('Returning Location: %s' % url)
return web.accepted()
开发者ID:goura,项目名称:karesansui,代码行数:42,代码来源:hostby1networkby1.py
注:本文中的pysilhouette.command.dict2command函数示例由纯净天空整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论