aws SAM 产生cloudwatch logs 给lambda表达式处理

AWS SAM（Serverless Application Model）提供了一个方便的方式来生成和管理 Lambda 函数和其他服务资源。如果您想将 CloudWatch 日志发送到 Lambda 函数进行处理，可以通过以下步骤实现：

1. 在 `template.yaml` 文件中为 Lambda 函数定义一个 CloudWatch 日志组，例如：

   Resources:
     MyFunction:
       Type: AWS::Serverless::Function
       Properties:
         ...
         Environment:
           Variables:
             ...
         Policies:
           - AWSLambdaBasicExecutionRole
         Events:
           MyEvent:
             Type: Schedule
             Properties:
               Schedule: rate(1 minute)
       MyFunctionLogGroup:
         Type: AWS::Logs::LogGroup
         Properties:
           LogGroupName: "/aws/lambda/MyFunction"
           RetentionInDays: 7

这将在 CloudWatch 中创建一个日志组 `/aws/lambda/MyFunction`，并将其与 Lambda 函数 `MyFunction` 关联。

2. 在 Lambda 函数中添加 CloudWatch 日志处理程序。在 Python 中，您可以使用 `boto3` 库和 `json` 模块来解析和处理日志事件，例如：

   import boto3
   import json

   def lambda_handler(event, context):
       logs = boto3.client('logs')
       for log_event in event['awslogs']['data']:
           payload = json.loads(log_event['message'])
           # Process the log message here

3. 在 `template.yaml` 文件中将 Lambda 函数与 CloudWatch 日志组关联，例如：

   Resources:
     MyFunction:
       Type: AWS::Serverless::Function
       Properties:
         ...
         Environment:
           Variables:
             ...
         Policies:
           - AWSLambdaBasicExecutionRole
         Events:
           MyEvent:
             Type: Schedule
             Properties:
               Schedule: rate(1 minute)
       MyFunctionLogGroup:
         Type: AWS::Logs::LogGroup
         Properties:
           LogGroupName: "/aws/lambda/MyFunction"
           RetentionInDays: 7
       MyFunctionLogSubscriptionFilter:
         Type: AWS::Logs::SubscriptionFilter
         Properties:
           DestinationArn: !GetAtt MyFunction.Arn
           FilterPattern: ""
           LogGroupName: !Ref MyFunctionLogGroup

这将在 CloudWatch 日志组 `/aws/lambda/MyFunction` 中添加一个订阅过滤器，将所有日志事件转发到 `MyFunction` Lambda 函数进行处理。

注意：这只是一个简单的示例，实际的实现可能会因环境和需求而异。