作业接口文档

#!/usr/bin/python
# -*- coding: utf-8 -*-

# 引入云API入口模块
from QcloudApi.qcloudapi import QcloudApi

# 公共配置
module = 'batch'

config = {
    'Region': 'ap-guangzhou',  # 目标地域
    'secretId': '您的secretId',
    'secretKey': '您的secretKey',
}

service = QcloudApi(module, config)

try:
    action = 'SubmitJob'
    action_params = {
        'Version': '2017-03-12',
        'Job': {
            'JobName': 'batch-job', # 作业名称
            'JobDescription': 'batch job',  # 作业描述
            'Priority': '1',  # 作业优先级
            'Tasks': [
                {
                    'TaskName': 'task1',  # 任务名称
                    'TaskInstanceNum':  1,  # 任务实例数目
                    'FailedAction': 'FAST_INTERRUPT',  # 失败作业的处理方式
                    'Application': {
                        'DeliveryForm': 'LOCAL',  # 程序包来源
                        'Command': 'echo hello',  # 命令行
                        },
                    'EnvId': 'env-gbyctcy9',  # 计算环境标识
                    'RedirectInfo': {
                        'StdoutRedirectPath': 'cos://bucketgz-1251783334.cos.ap-guangzhou.myqcloud.com/stdout/',  # 标准输出存储路径
                        'StderrRedirectPath': 'cos://bucketgz-1251783334.cos.ap-guangzhou.myqcloud.com/stderr/',  # 标准错误存储路径
                        }
                    }
                ]
            },
        'Placement': {
            'Zone': 'ap-guangzhou-2'  # 可用区
            },
        }
    print(service.generateUrl(action, action_params))
    print(service.call(action, action_params))
except Exception as e:
    import traceback
    print('traceback.format_exc():
%s' % traceback.format_exc())

try:
    action = 'TerminateJob'
    action_params = {
        'Version': '2017-03-12',
        'JobId': 'job-8kwnzki7',  # 作业标识
        }
    print(service.generateUrl(action, action_params))
    print(service.call(action, action_params))
except Exception as e:
    import traceback
    print('traceback.format_exc():
%s' % traceback.format_exc())

try:
    action = 'DeleteJob'
    action_params = {
        'Version': '2017-03-12',
        'JobId': 'job-8kwnzki7',  # 作业标识
        }
    print(service.generateUrl(action, action_params))
    print(service.call(action, action_params))
except Exception as e:
    import traceback
    print('traceback.format_exc():
%s' % traceback.format_exc())

try:
    action = 'DescribeJobSubmitInfo'
    action_params = {
        'Version': '2017-03-12',
        'JobId': 'job-8kwnzki7',  # 作业标识
        }
    print(service.generateUrl(action, action_params))
    print(service.call(action, action_params))
except Exception as e:
    import traceback
    print('traceback.format_exc():
%s' % traceback.format_exc())

try:
    action = 'DescribeJob'
    action_params = {
        'Version': '2017-03-12',
        'JobId': 'job-8kwnzki7',  # 作业标识
        }
    print(service.generateUrl(action, action_params))
    print(service.call(action, action_params))
except Exception as e:
    import traceback
    print('traceback.format_exc():
%s' % traceback.format_exc())

try:
    action = 'DescribeJobs'
    action_params = {
        'Version': '2017-03-12'
        }
    print(service.generateUrl(action, action_params))
    print(service.call(action, action_params))
except Exception as e:
    import traceback
    print('traceback.format_exc():
%s' % traceback.format_exc())

try:
    action = 'DescribeTask'
    action_params = {
        'Version': '2017-03-12',
    'JobId': 'job-8kwnzki7',  # 作业标识
    'TaskName': 'task A'  # 任务名称
        }
    print(service.generateUrl(action, action_params))
    print(service.call(action, action_params))
except Exception as e:
    import traceback
    print('traceback.format_exc():
%s' % traceback.format_exc())

try:
    action = 'TerminateTaskInstance'
    action_params = {
        'Version': '2017-03-12',
    'JobId': 'job-8kwnzki7',  # 作业标识
    'TaskName': 'task A',  # 任务名称
    'TaskInstanceIndex': 1  # 第1个实例
        }
    print(service.generateUrl(action, action_params))
    print(service.call(action, action_params))
except Exception as e:
    import traceback
    print('traceback.format_exc():
%s' % traceback.format_exc())