运维编排场景系列-----流水线操作函数计算

2022-01-30 00:26:09

函数计算（FC）是事件驱动的全托管计算服务。使用函数计算，您无需采购与管理服务器等基础设施，只需编写并上传代码。在函数计算的基础上，为实现自动创建与运行函数计算，以及输出函数计算的运行结果。为简单执行上述的流水先操作，此时可以使用OOS服务来实现一系列的自动化动作。

前提条件

编写业务需求的脚本代码

模版说明：

本模版主要功能为：

创建资源栈
1. 创建FC服务
2. 创建FC函数
3. 运行FC函数
等待资源栈至创建成功状态
删除资源栈
输出FC函数运行的结果

Description:
  en: Run function (FC) and output the result.
  zh-cn: 运行函数计算(FC)并输出结果。
FormatVersion: OOS-2019-06-01
Parameters:
  Handler:
    Type: String
    Description:
      en: 'Function execution entry, specific format and language related.'
      zh-cn: function执行的入口，具体格式和语言相关
  Runtime:
    Type: String
    Description:
      en: Function runtime environment.
      zh-cn: function的运行环境。
    AllowedValues:
      - nodejs6
      - nodejs8
      - python2.7
      - python3
      - java8
  Timeout:
    Type: Number
    Description:
      en: Function timeout.
      zh-cn: function运行的超时时间。
    MinValue: 1
    MaxValue: 300
    Default: 3
  SourceCode:
    Type: String
    Description:
      en: Function code.
      zh-cn: function的运行代码脚本。
  ParameterValue:
    Type: String
    Description:
      en: The value of the script code.
      zh-cn: 脚本代码的传参。
  OOSAssumeRole:
    Description: The RAM role to be assumed by OOS.
    Type: String
    Default: OOSServiceRole
RamRole: '{{ OOSAssumeRole }}'
Tasks:
  - Name: createStack
    Action: 'ACS::ExecuteAPI'
    Description:
      en: Create a resource stack.
      zh-cn: 创建资源栈。
    Properties:
      Service: ROS
      API: CreateStack
      Parameters:
        StackName: 'OOS-{{ACS::ExecutionId}}'
        TimeoutInMinutes: 10
        DisableRollback: false
        Parameters:
          - ParameterKey: ParameterKeys
            ParameterValue: '{{ ParameterValue }}'
          - ParameterKey: FunctionName
            ParameterValue: 'OOS-{{ACS::ExecutionId}}'
          - ParameterKey: ServiceName
            ParameterValue: 'OOS-{{ACS::ExecutionId}}'
        TemplateBody: |-
          {
              "ROSTemplateFormatVersion": "2015-09-01",
              "Parameters": {
                  "ParameterKeys": {
                    "Type": "CommaDelimitedList"
                  },
                  "ServiceName": {
                      "Type": "String",
                      "Default": "test-fc-service"
                  },
                  "FunctionName": {
                      "Type": "String",
                      "Default": "test-fc-function"
                  },
                  "ExecuteVersion": {
                      "Type": "Number",
                      "Default": 0
                  }
              },
              "Resources": {
                  "Service": {
                      "Type": "ALIYUN::FC::Service",
                      "Properties": {
                          "ServiceName": {
                          "Ref": "ServiceName"
                          }
                      }
                  },
                  "Function": {
                      "Type": "ALIYUN::FC::Function",
                      "DependsOn": "Service",
                      "Properties": {
                              "ServiceName": {
                              "Ref": "ServiceName"
                          },
                              "FunctionName": {
                              "Ref": "FunctionName"
                          },
                          "Code": {
                              "SourceCode": "{{ SourceCode }}"
                          },
                          "Handler": "{{ Handler }}",
                          "Runtime": "{{ Runtime }}",
                          "Timeout": "{{ Timeout }}"
                          }
                      },
                      "FunctionInvoker": {
                          "Type": "ALIYUN::FC::FunctionInvoker",
                          "DependsOn": "Function",
                          "Properties": {
                              "ServiceName": {
                                  "Ref": "ServiceName"
                              },
                              "FunctionName": {
                                  "Ref": "FunctionName"
                              },
                              "Async": false,
                              "Event": {
                                  "Fn::Join": [",", {"Ref": "ParameterKeys"}]
                              },
                              "ExecuteVersion": {
                                  "Ref": "ExecuteVersion"
                              }
                          }
                      }
                  },
                  "Outputs": {
                      "Result": {
                          "Value": {
                              "Fn::Replace" : [
                              {
                                  "FcResult": {
                                  "Fn::GetAtt": [
                                      "FunctionInvoker",
                                      "Result"
                                  ]
                                  }
                              },
                              "FcResult"
                              ]
                          }
                      }
                  }
              }
    Outputs:
      StackId:
        Type: String
        ValueSelector: StackId
  - Name: untilStackReady
    Action: 'ACS::WaitFor'
    OnError: deleteStack
    Description:
      en: Wait the stack status util CREATE_COMPLETE.
      zh-cn: 等待资源栈至创建成功状态。
    Properties:
      Service: ROS
      API: GetStack
      Parameters:
        StackId: '{{createStack.StackId}}'
      DesiredValues:
        - CREATE_COMPLETE
      StopRetryValues:
        - CREATE_FAILED
        - CHECK_FAILED
        - ROLLBACK_FAILED
        - ROLLBACK_COMPLETE
      PropertySelector: Status
    Outputs:
      Result:
        Type: String
        ValueSelector: 'Outputs[].OutputValue'
  - Name: deleteStack
    Action: 'ACS::ExecuteApi'
    Description:
      en: Delete the stack.
      zh-cn: 删除资源栈。
    Properties:
      Service: ROS
      API: DeleteStack
      Parameters:
        StackId: '{{createStack.StackId}}'
Outputs:
  Result:
    Type: String
    Value: '{{ untilStackReady.Result }}'

模版参数说明：

参数	说明	示例
Handler	function执行的入口，具体格式和语言相关（注：前部分为脚本文件名，后部分为脚本内函数名）	index.lottery
Runtime	function的运行环境，目前支持: - nodejs6 - nodejs8 - python2.7 - python3 - java8	python3
Timeout	function运行的超时时间，单位为秒，最小1秒，最长5分钟，默认3秒。	3
SourceCode	脚本代码。（注：需要将换行转化为\n）	import randomndef lottery(event, context):\n return '恭喜%s中奖' % random.choice([name.strip() for name in event.decode('utf-8').split(',')])
ParameterValue	用于脚本的参数值（注：在脚本中使用参数时，传入到脚本的参数为Bytes类型，需要在脚本代码中转译成需要的编码类型。）	a,b,c,d
OOSAssumeRole	可选参数。 - （默认设置）当前账号的已有权限：执行您使用的账号的权限动作。请确保您拥有创建自定义镜像涉及的所有ECS API调用权限。 - 指定RAM角色，使用该角色的权限：如果指定了RAM角色名称，OOS扮演该RAM角色执行运维任务。	当前账号的已有权限