CloudWatch Event规则能否结合事件模式与调度表达式及Lambda自定义Detail获取问题

问题分析 #

CloudWatch Event规则无法同时配置schedule_expression和event_pattern，改用aws_cloudwatch_event_target的input参数传递自定义数据时，Go Lambda无法获取数据，通常是以下两个原因：

• Terraform中input参数的JSON字符串格式错误（未正确转义或语法有误）
• Go Lambda代码未正确解析自定义事件结构

正确配置示例 #

1. Terraform配置 #

确保input参数是合法的转义JSON字符串，示例如下：

resource "aws_cloudwatch_event_rule" "schedule_rule" {
  name                = "my-scheduled-rule"
  schedule_expression = "rate(5 minutes)"
  description         = "Scheduled rule to trigger Lambda with custom data"
}

resource "aws_cloudwatch_event_target" "lambda_target" {
  rule      = aws_cloudwatch_event_rule.schedule_rule.name
  arn       = aws_lambda_function.my_lambda.arn
  target_id = "my-lambda-target"

  # 注意：内部双引号需转义，确保JSON格式合法
  input = <<EOF
"{\"key1\": \"value1\", \"key2\": \"value2\", \"custom_detail\": {\"foo\": \"bar\"}}"
EOF
}

# 配置CloudWatch Events调用Lambda的权限
resource "aws_lambda_permission" "cloudwatch_invoke" {
  statement_id  = "AllowCloudWatchEventsInvokeLambda"
  action        = "lambda:InvokeFunction"
  function_name = aws_lambda_function.my_lambda.function_name
  principal     = "events.amazonaws.com"
  source_arn    = aws_cloudwatch_event_rule.schedule_rule.arn
}

2. Go Lambda代码 #

直接根据input的JSON结构定义对应结构体进行解析，无需使用CloudWatch Event默认结构：

package main

import (
	"context"
	"encoding/json"
	"fmt"
	"github.com/aws/aws-lambda-go/lambda"
)

// 自定义结构体，与input中的JSON结构一一对应
type CustomEvent struct {
	Key1        string                 `json:"key1"`
	Key2        string                 `json:"key2"`
	CustomDetail map[string]interface{} `json:"custom_detail"`
}

func handler(ctx context.Context, event CustomEvent) error {
	fmt.Printf("Received custom event: %+v\n", event)
	fmt.Printf("Custom detail foo value: %s\n", event.CustomDetail["foo"].(string))
	return nil
}

func main() {
	lambda.Start(handler)
}

常见错误排查 #

• Terraform input格式错误：若未正确转义JSON内部双引号，会导致传递无效数据，必须确保字符串是合法的JSON格式（如"{\"key\": \"value\"}"）。
• Go代码解析错误：若仍使用CloudWatch Event默认结构体（如events.CloudWatchEvent），会因结构不匹配解析失败，可先将事件解析为map[string]interface{}查看原始数据：

func handler(ctx context.Context, event map[string]interface{}) error {
	rawJSON, _ := json.Marshal(event)
	fmt.Println("Raw event data:", string(rawJSON))
	return nil
}

• 权限缺失：必须配置aws_lambda_permission授权CloudWatch Events调用Lambda，否则规则触发后Lambda收不到任何事件。

内容的提问来源于stack exchange，提问作者ibrahim jamil