ACS::ECS::AlarmSpotPriceOrDiscountBySingleScalingGroup.yml

FormatVersion: OOS-2019-06-01
Description:
  name-en: ACS::ECS::AlarmSpotPriceOrDiscountBySingleScalingGroup
  name-zh-cn: 监控单个伸缩组内实例的现价或折扣的阈值
  en: Alarm notification when spot instance discount or spot price exceeds threshold in the single scaling group existing instances
  zh-cn: 监控弹性伸缩组弹出的预付费实例的最新价格与折扣，超出阈值时发出报警通知
Parameters:
  regionId:
    Description:
      en: The ID of region
      zh-cn: 地域ID
    Type: String
  threshold:
    Description:
      en: 'The discount threshold(example:10 is 1% off, 50 is 50% off)'
      zh-cn: 折扣阈值（例：输入10是1折，50为5折）
    Type: Number
  taskType:
    Description:
      en: Monitoring threshold task type
      zh-cn: 监控阈值的任务类型
    Type: String
  scalingGroupId:
    Description:
      en: The ID of scaling group
      zh-cn: 弹性伸缩组ID
    Type: String
Tasks:
  - Name: describeScalingInstances
    Action: 'ACS::ExecuteAPI'
    Description:
      en: Queries the scaling ECS instance IDs
      zh-cn: 获取伸缩组内ECS实例的ID
    Properties:
      Service: ESS
      API: DescribeScalingInstances
      Parameters:
        RegionId: '{{ regionId }}'
        ScalingGroupId: '{{ scalingGroupId }}'
    Outputs:
      instanceIds:
        Type: List
        ValueSelector: '.ScalingInstances.ScalingInstance[].InstanceId'
  - Name: wetherExistInstance
    Action: 'ACS::Choice'
    Description:
      en: Check wether an alarm notification is required
      zh-cn: 检测是否需要发报警通知
    Properties:
      DefaultTask: describeInstances
      Choices:
        - When:
            'Fn::Equals':
              - []
              - '{{ describeScalingInstances.instanceIds }}'
          NextTask: 'ACS::END'
  - Name: describeInstances
    Action: 'ACS::ExecuteAPI'
    Description:
      en: Queries instance type and zone of the ECS instance
      zh-cn: 获取ECS实例的规格和可用区
    Properties:
      Service: ECS
      API: DescribeInstances
      Parameters:
        RegionId: '{{ regionId }}'
        InstanceIds:
          - '{{ ACS::TaskLoopItem }}'
    Outputs:
      instanceTypeAndZone:
        Type: Json
        ValueSelector: '.Instances.Instance[] | {"instanceType":.InstanceType, "zoneId": .ZoneId}'
    Loop:
      Items: '{{ describeScalingInstances.instanceIds }}'
      MaxErrors: 100
      Concurrency: 50
      Outputs:
        instanceTypeAndZones:
          AggregateField: instanceTypeAndZone
          AggregateType: 'Fn::ListJoin'
  - Name: describeScalingGroups
    Action: 'ACS::ExecuteAPI'
    Description:
      en: Queries the name of scaling group
      zh-cn: 获取伸缩组名称
    Properties:
      Service: ESS
      API: DescribeScalingGroups
      Parameters:
        RegionId: '{{ regionId }}'
        ScalingGroupId1: '{{ scalingGroupId }}'
    Outputs:
      scalingGroupName:
        Type: String
        ValueSelector: '.ScalingGroups.ScalingGroup[].ScalingGroupName'
  - Name: outPutSingleScalingGroupInfo
    Action: 'ACS::ECS::AlarmSpotPriceOrDiscountByScalingGroupInstance'
    Description:
      en: Monitor discounts or prices of all created spot instance types under a single scaling group
      zh-cn: 监控单个伸缩组下所有预付费实例类型的折扣与价格
    Properties:
      regionId: '{{regionId}}'
      threshold: '{{ threshold }}'
      taskType: '{{ taskType }}'
      instanceType:
        'Fn::Jq':
          - First
          - .instanceType
          - '{{ ACS::TaskLoopItem }}'
      zoneId:
        'Fn::Jq':
          - First
          - .zoneId
          - '{{ ACS::TaskLoopItem }}'
    Outputs:
      monitorInfo:
        Type: Json
        ValueSelector: discountInfo
    Loop:
      Items:
        'Fn::Jq':
          - First
          - '. | unique'
          - '{{ describeInstances.instanceTypeAndZones }}'
      MaxErrors: 100
      Concurrency: 10
      Outputs:
        scalingGroupMonitorInfos:
          AggregateField: monitorInfo
          AggregateType: 'Fn::ListJoin'
Outputs:
  singleMonitorInfo:
    Type: String
    Value:
      'Fn::If':
        - 'Fn::Equals':
            - []
            - 'Fn::MergeList':
                - '{{ outPutSingleScalingGroupInfo.scalingGroupMonitorInfos }}'
        - Null
        - 'Fn::Jq':
            - First
            - '.[0] as $item | "\n### 伸缩组名称：{{describeScalingGroups.scalingGroupName}}\n### 伸缩组ID：{{scalingGroupId}}\n| 机型 |  可用区|现价|折扣%|\n|:----|:----|:----:|:----|\n" + $item'
            - - 'Fn::Jq':
                  - First
                  - '.[]|split(", ") | join("") |split("\n,")| join("")| split("\n,|")|join("") |split("||")|join("|")'
                  - 'Fn::Jq':
                      - All
                      - '.[1]=""|join("|")'
                      - 'Fn::Jq':
                          - All
                          - '.[1]=""| .[1]=.[0] | .[0]="" | join("|")'
                          - 'Fn::Jq':
                              - All
                              - map(.) | join("\n|")
                              - 'Fn::Jq':
                                  - All
                                  - '.[] | map(.[] | tostring)| join(" |")'
                                  - 'Fn::Jq':
                                      - All
                                      - 'map(.| .actualDiscount=.actualDiscount+" |\n," )'
                                      - 'Fn::MergeList':
                                          - '{{ outPutSingleScalingGroupInfo.scalingGroupMonitorInfos }}'