快速入门 - 运维编排服务

本节介绍如何快速使用OOS Python SDK完成常见操作，如创建模板、启动执行、查询执行等。

创建模板

以下代码用于创建模板：

# coding: utf-8
from aliyunsdkcore.client import AcsClient
from aliyunsdkoos.request.v20190601.CreateTemplateRequest import CreateTemplateRequest
client = AcsClient(ak='<AccessKeyId>', secret='<AccessKeySecret>', region_id='cn-hangzhou')
content = '''
{
  "FormatVersion": "OOS-2019-06-01",
  "Description": "Descirbe instances of given status",
  "Parameters": {
    "Status": {
      "Type": "String",
      "Description": "(Required) The status of the Ecs instance."
    }
  },
  "Tasks": [
    {
      "Properties": {
        "Parameters": { "Status": "{{ Status }}" },
        "API": "DescribeInstances",
        "Service": "ECS"
      },
      "Name": "describeInstances",
      "Action": "ACS::ExecuteAPI"
    }
  ]
}
'''
def create_template(template_name, content):
    """
    创建模板
    """
    request = CreateTemplateRequest()
    request.set_TemplateName(template_name)
    request.set_Content(content)
    resp = client.do_action_with_exception(request)
    return resp
resp = create_template(template_name='MyTemplate', content=content)
print(resp)

启动执行

以下代码用于启动执行：

# coding: utf-8
import json
from aliyunsdkcore.client import AcsClient
from aliyunsdkoos.request.v20190601.StartExecutionRequest import StartExecutionRequest
client = AcsClient(ak='<AccessKeyId>', secret='<AccessKeySecret>', region_id='cn-hangzhou')
def start_execution(template_name, parameters=None):
    """
    启动执行
    """
    request = StartExecutionRequest()
    request.set_TemplateName(template_name)
    if parameters:
        parameters = json.dumps(parameters)
        request.set_Parameters(parameters)
    resp = client.do_action_with_exception(request)
    return resp
resp = start_execution(template_name='MyTemplate', parameters={"Status":"Running"})
print(resp)

查询执行

以下代码用于查询执行：

# coding: utf-8
from aliyunsdkcore.client import AcsClient
from aliyunsdkoos.request.v20190601.ListExecutionsRequest import ListExecutionsRequest
client = AcsClient(ak='<AccessKeyId>', secret='<AccessKeySecret>', region_id='cn-hangzhou')
def list_exexutions(execution_id=None):
    """
    查询执行
    """
    request = ListExecutionsRequest()
    if execution_id:
        request.set_ExecutionId(execution_id)
    resp = client.do_action_with_exception(request)
    return resp
resp = list_exexutions(execution_id='<ExecutionId>')
print(resp)