事件总线EventBridge：通过EventBridge快速订阅ECS事件

背景信息

适用场景

• 订阅指定的ECS事件，触发钉钉、短信、邮箱通知等。

• 将指定的ECS事件，通过公网或者VPC网络推送到下游HTTP/HTTPS服务。

• 汇总多个云账号下的ECS事件。

• 指定的ECS事件发生时，通过函数计算触发特定动作。

• 当ECS事件时延较高、事件量较大时，将其投递至轻量消息队列（原 MNS）来订阅事件。

前提条件

• 开通事件总线EventBridge并授权。

• 创建钉钉机器人，记录Webhook地址和密钥。

• 创建函数和服务，更多信息，请参见管理服务和管理函数。

• 创建轻量消息队列（原 MNS）队列，更多信息，请参见开通轻量消息队列（原 MNS）并授权和创建队列。

步骤一：选用云服务专用事件总线

云服务专用事件总线即default总线，是EventBridge默认创建的总线，阿里云上各个云产品会实时将产品内产生的事件，通过多种渠道实时投递到default总线，您可以在default总线上查找和订阅各个云产品的事件。

步骤二：创建ECS事件订阅规则

1. 在事件总线页面，单击左侧导航栏的事件规则，然后单击创建规则。

2. 在创建规则面板，完成以下操作。

   1. 在配置基本信息页签，在名称文本框输入规则名称，在描述文本框输入规则的描述，然后单击下一步。

   2. 在配置事件模式页签，完成以下配置，然后单击下一步。

      • 单击阿里云官方事件源页签。

      • 在事件源下拉列表选择acs.ecs。

      • 在事件类型下拉列表选择需要订阅的事件类型。可同时选择订阅多个事件类型。

      • 在事件模式调试中，可查看订阅的事件类型的示例。例如，事件类型选择ecs.Instance.StateChange 实例生命周期状态变化时，对应的示例如下。

        {
          "id": "45ef4dewdwe1-7c35-447a-bd93-fab****",
          "source": "acs.ecs",
          "specversion": "1.0",
          "subject": "acs.ecs:cn-hangzhou:123456789098****:215672",
          "time": "2020-11-19T21:04:41Z",
          "type": "ecs:Instance:StateChange",
          "aliyunaccountid": "123456789098****",
          "aliyunpublishtime": "2020-11-19T21:04:42Z",
          "aliyuneventbusname": "default",
          "aliyunregionid": "cn-hangzhou",
          "aliyunpublishaddr": "172.25.XX.XX",
          "data": {
            "instanceName": "iZ0jl0kyquo46h****",
            "instanceType": "ecs.c6.large",
            "privateIpAddress": "172.21.XX.XX",
            "publicIpAddress": "8.37.XX.XX",
            "resourceId": "i-0jl0kyquo46****",
            "resourceType": "ALIYUN::ECS::Instance",
            "spotStrategy": "SpotWithPriceLimit",
            "state": "Running"
          }
        }

   3. 在配置事件目标页签，选择不同的服务类型，设置推送场景。

      场景一：推送至轻量消息队列（原 MNS）

      使用轻量消息队列（原 MNS）来订阅事件适用于对事件时延要求较高、事件量较大的场景。轻量消息队列（原 MNS）费用详情请参见计费说明。

      • 服务类型：选择轻量消息队列（原 MNS）。

      • 队列：选择已创建的队列。

      • 消息体（body）：选择完整事件。

      • 开启 Base64 解码：选择是。开启Base64 编码，会帮助您将数据编码后投递至目标轻量消息队列（原 MNS）中的队列。

      服务类型为轻量消息队列（原 MNS）时，可通过NetworkInterfaceDemo.zip监听轻量消息队列（原 MNS）消息获取事件。

      场景二：推送至钉钉

      • 服务类型：选择钉钉。

      • 地址：输入钉钉机器人的Webhook地址。

      • 密钥：输入钉钉机器人密钥。

      • 推送内容：您可以通过EventBridge的模板能力，将上面事件中的参数推送给钉钉机器人，例如，推送ECS实例的名称（instanceName）和运行状态（state），配置如下：

        • 变量：通过JsonPath指定需要获取的事件中的字段信息，并设置变量名称。

          {
            "instanceName":"$.data.instanceName",
            "state":"$.data.state"
          }

        • 模板：按照钉钉机器人需要的格式定义模板，并在模板中引入上面定义的变量。

          {
            "msgtype": "text",
            "text": {
                "content": "${instanceName} state is ${state}" 
            } 
          }

      场景三：推送至下游HTTP服务

      • 服务类型：选择HTTP或者HTTPS。

      • URL：配置接收事件的URL地址。

      • Body：配置接收事件的内容格式。EventBridge支持将事件转换后，按需要的格式推送给HTTP目标端，目前支持四种转换格式：完整事件、部分事件、固定值、模板。更多信息，请参见事件内容转换。

      • 网络类型：

        • 公网：通过公网访问目标URL地址。

        • 专有网络：如果目标URL的地址未暴露公网，可以选择专有网络，需设置VPC ID、VSwitch ID和安全组ID。

      场景四：推送后触发动作

      如果希望指定ECS事件发生时，触发某个更加个性化的动作，可以将服务类型设置为函数计算。把事件推送到指定的函数，在函数计算里通过代码编辑个性化的操作。

      • 服务类型：选择函数计算。

      • 服务：函数计算里创建的服务名称。

      • 函数：函数计算里创建的函数名称。

      • 事件：配置接收事件的内容格式。EventBridge支持将事件转换后，按需要的格式推送给函数计算。目前支持四种转换模板：完整事件、部分事件、固定模板模版。详细信息，请参见事件内容转换。

      • 执行方式：

        • 同步：函数计算接收到事件，并且函数成功处理完事件后则响应成功。

        • 异步：函数计算成功接收到事件后，则认为响应成功。

        更多信息，请参见路由到函数计算。

      场景五：汇总多个云账号下的ECS事件

      EventBridge支持将不同账号、不同地域下的ECS事件汇总到同一个地域的同一个账号下的事件总线，需要选择服务类型为EventBridge事件总线。

      • 目标类型：

        • 同账号总线：投递给当前账号的其他总线。

        • 跨账号总线：投递给其他账号的总线。如需选择跨账号投递，需要进行账号授权，详细信息，请参见路由到事件总线EventBridge。

      • 地域：支持中国内地跨地域投递和国外地域之间相互投递。

      • 事件总线：要投递的目标总线名称。

      • 事件：默认投递完整事件且不可更改。

      在配置事件目标页签下方，您可以根据业务需要配置重试和死信策略。详情请参见重试和死信。

      更多场景，请参见目标服务类型。

步骤三：触发事件

本文以ecs.Instance.StateChange 实例生命周期状态变化事件类型为例，触发事件需要修改ECS实例的运行状态。

1. 登录ECS管理控制台。

2. 在左侧导航栏，选择实例与镜像 > 实例。

3. 在顶部菜单栏，选择目标资源所在的地域。

4. 在目标ECS实例右侧操作列，选择 > 实例状态，修改实例的运行状态。

步骤四：查看投递结果

1. 查询ECS是否产生事件。

   EventBridge支持根据时间范围、事件类型、订阅规则名称、事件ID（与ECS事件ID一致）来查询搜索产生的ECS事件。操作步骤，请参见查询事件。

2. 查询ECS事件的订阅投递结果。

   通过上一步查询到的事件ID，可以单击事件ID右侧操作列的事件轨迹查看事件推送轨迹，轨迹包含推送的目标、状态、次数、时间。

事件的监控报警

您可以在的EventBridge监控大盘中看到创建的ECS事件订阅任务的调用次数，推送成功率、推送延迟等。根据具体业务场景诉求配置报警策略。

您可以在监控页面为EventBridge的资源设置报警规则。当资源符合报警规则时，云监控自动发送报警通知。操作步骤，请参见设置报警规则。

重试和死信

事件写入EventBus之后，EventBridge保障事件能被推送到下游至少一次。当下游事件接收端出现异常（如宕机、服务不可用、网络抖动等），导致接收端无法正常接收事件时，EventBridge支持多种方式处理这些异常，包括：重试策略、容错策略、死信队列。您可以在步骤二：创建ECS事件订阅规则中，配置重试和死信策略，保障事件会被正确投递。