事件总线EventBridge：通过Terraform实现IaC自动化部署事件总线

背景信息

IaC是一种以代码来配置和管理虚拟机、网络等基础设施的实践方法。通过将基础设施代码化、版本化来取代传统的手工操作基础设施。传统的基础设施管理方法是人工手动处理模式，不仅效率低下，而且还有很多人为操作的风险。在IaC的实践中，开发者通过代码描述基础设施的配置及变更，再执行代码完成配置和变更，就可以在几分钟后得到所需的虚拟机、网络等云上的服务，极大地缩短了部署时间，同时还能够保证多个环境的配置一致性，减少人为操作，降低了引入错误的概率。

HashiCorp Terraform是一个IT基础架构自动化编排工具。作为最主流的IaC工具之一，它提供了强大的自动化管理基础设施的能力。Terraform的命令行接口（CLI）提供一种简单机制，用于将配置文件部署到阿里云或其他任意支持的云上，并对其进行版本控制。阿里云的大多数产品（包括事件总线EventBridge）都对Terraform进行支持，使得跨多云部署基础设施变得简单。更多信息，请参见Terraform产品介绍。

本文以Terraform为例介绍基于IaC理念自动化部署基础设施的案例。

使用的资源

自定义总线触发函数计算

当您的应用产生的事件是通过函数计算FC（Function Compute）进行处理时，就可以通过事件总线EventBridge的自定义事件源和函数计算事件目标来实现，与传统控制台部署方式不同，本案例使用Terraform工具自动化部署自定义总线与函数计算服务。

1. 创建2_trigger_function.tf文件，声明自定义总线、自定义事件源、函数计算服务、函数和过滤自定义事件源的规则。

   # 定义变量
   variable "region_id" {
     type    = string
     default = "cn-shenzhen"
   }
   
   # 配置阿里云Provider
   provider "alicloud" {
     region = var.region_id
   }
   
   # 获取当前账号信息
   data "alicloud_caller_identity" "current" {}
   
   # 创建自定义事件总线
   resource "alicloud_event_bridge_event_bus" "demo_event_bus" {
     event_bus_name = "demo_event_yiyi"
     description    = "This is a demo event bus."
   }
   
   # 创建自定义事件源
   resource "alicloud_event_bridge_event_source" "demo_event_source" {
     event_bus_name         = alicloud_event_bridge_event_bus.demo_event_bus.event_bus_name
     event_source_name      = "demo_event_source_yiyi"
     description            = "This is a demo event source."
     linked_external_source = false
   }
   
   # 创建函数计算服务
   resource "alicloud_fc_service" "fc_service" {
     name        = "eb-fc-service"
     description = "This service handles events from EventBridge."
     publish     = true
   }
   
   # 自动生成Python脚本文件
   resource "local_file" "python_script" {
     content  = <<EOF
   # -*- coding: utf-8 -*-
   import logging
   
   def handler(event, context):
       logger = logging.getLogger()
       logger.info('Event: ' + str(event))
       return str(event)
   EOF
     filename = "${path.module}/src/index.py"
   }
   
   # 将Python脚本文件打包成ZIP
   data "archive_file" "code" {
     type        = "zip"
     source_dir  = "${path.module}/src"
     output_path = "${path.module}/code.zip"
     depends_on = [local_file.python_script]
   }
   
   # 创建OSS Bucket
   resource "alicloud_oss_bucket" "code_bucket" {
     bucket = "fc-code-bucket-${random_string.random_suffix.result}"
   }
   
   # 生成随机字符串后缀确保OSS Bucket名称的唯一性
   resource "random_string" "random_suffix" {
     length  = 8
     special = false
     upper   = false
   }
   
   # 将ZIP包上传到OSS
   resource "alicloud_oss_bucket_object" "function_code" {
     bucket = alicloud_oss_bucket.code_bucket.bucket
     key    = "index.py.zip"
     source = data.archive_file.code.output_path
   }
   
   # 创建函数计算函数，使用OSS中的代码
   resource "alicloud_fc_function" "fc_function" {
     service     = alicloud_fc_service.fc_service.name
     name        = "eb-fc-function"
     description = "This function executes based on EventBridge rules."
     oss_bucket  = alicloud_oss_bucket.code_bucket.bucket
     oss_key     = alicloud_oss_bucket_object.function_code.key
     memory_size = 128
     runtime     = "python3"
     handler     = "index.handler"
   }
   
   # 在事件总线中创建事件规则
   resource "alicloud_event_bridge_rule" "demo_rule" {
     event_bus_name = alicloud_event_bridge_event_bus.demo_event_bus.event_bus_name
     rule_name      = "demo_rule"
     description    = "Rule for triggering Function Compute on events."
     filter_pattern = jsonencode({
       "source" : [alicloud_event_bridge_event_source.demo_event_source.id]
     })
     lifecycle {
       ignore_changes = [
         targets
       ]
     }
     targets {
       target_id = "demo-fc-target"
       type      = "acs.fc.function"
       endpoint  = "acs:fc:${var.region_id}:${data.alicloud_caller_identity.current.account_id}:services/${alicloud_fc_service.fc_service.name}.LATEST/functions/${alicloud_fc_function.fc_function.name}"
   
       param_list {
         resource_key = "serviceName"
         form         = "CONSTANT"
         value        = alicloud_fc_service.fc_service.name
       }
       param_list {
         resource_key = "functionName"
         form         = "CONSTANT"
         value        = alicloud_fc_function.fc_function.name
       }
       param_list {
         resource_key = "Qualifier"
         form         = "CONSTANT"
         value        = "LATEST"
       }
       param_list {
         resource_key = "Body"
         form         = "ORIGINAL"
       }
     }
   }

2. 使用Terraform工具部署2_trigger_function.tf中创建的资源。

   1. 在命令行窗口执行初始化命令：terraform init。出现以下结果则表示初始化成功：

      

   2. 执行预览变更命令：terraform plan。在结果中可以预览到即将被创建的资源：

      

   3. 执行应用变更命令：terraform apply。在执行过程中，根据提示输入yes并按下Enter键，等待命令执行完成，若出现以下信息，则表示授权完成，出现以下结果则表示资源被创建成功：

      

3. 执行terraform show命令

   您可以使用以下命令查询Terraform已创建的资源详细信息：

   terraform show

   

   查看自定义事件总线和自定义事件源是否创建成功

   查看自定义事件总线和自定义事件源是否创建成功。

   1. 登录事件总线EventBridge控制台，在左侧导航栏，单击事件总线。

   2. 在顶部菜单栏，选择地域。

   3. 在事件总线页面，单击demo_event_yiyi。

   4. 在左侧导航栏，单击事件源，在事件源页面，单击demo_event_yiyi查看详情。

   查看函数计算服务和函数是否创建成功。

   1. 登录函数计算控制台，在左侧导航栏，单击服务及函数。

   2. 在顶部菜单栏，选择地域。

   3. 在服务及函数页面，单击eb-fc-service，然后查看函数详情。

   触发事件。

   1. 登录事件总线EventBridge控制台，在左侧导航栏，单击事件总线。

   2. 在顶部菜单栏，选择地域。

   3. 在事件总线页面，单击demo_event_yiyi。

   4. 在概览界面单击发布事件，在发布事件至自定义事件总线demo_event_yiyi面板，从自定义事件源下拉列表，选择demo_event_yiyi，单击确认。

   查看事件详情。

   1. 在demo_event_bus页面，单击事件追踪。

   2. 找到发布的事件，在其操作列，单击事件轨迹，查看事件已经成功投递到函数eb-fc-function上。

   删除创建资源

   本示例以介绍如何停用并删除资源。

   1. 在目标项目目录内执行以下命令，运行配置文件。

      terraform destroy

   2. 预期结果已成功停删除应用。