能否为单个AWS Lambda函数配置Kinesis与DynamoDB Streams两种事件源？

当然可以！AWS Lambda完全支持为单个函数配置多种不同类型的事件源，包括你提到的Kinesis Stream和DynamoDB Stream同时作为触发源——这是很常见的使用场景，官方其实是允许的，只是可能文档里没有单独把这种组合拎出来说明而已。

下面是一些关键的注意点和操作建议：

• 配置方法：不管是通过AWS控制台、AWS CLI还是基础设施即代码工具（比如CloudFormation、Terraform），你都可以分别为Lambda函数添加这两种事件源映射。比如在控制台操作时，进入目标Lambda函数的「配置」标签页，选择「触发器」，点击「添加触发器」，分别选择Kinesis和DynamoDB类型，依次完成各自的流关联、权限配置即可。

• 代码适配：由于Kinesis和DynamoDB流的事件结构差异很大，你的Lambda代码必须先判断当前触发请求的事件源类型，再执行对应的处理逻辑。可以通过检查事件中Records[0].eventSource字段来区分：

  • Kinesis流的事件源标识是aws:kinesis
  • DynamoDB流的事件源标识是aws:dynamodb

  这里给你一个Python示例片段，供参考：

  import base64
  
  def lambda_handler(event, context):
      # 先判断事件源类型
      if not event.get('Records'):
          return {"statusCode": 400, "body": "无效的事件格式"}
      
      event_source = event['Records'][0]['eventSource']
      
      if event_source == 'aws:kinesis':
          # 处理Kinesis流数据
          for record in event['Records']:
              raw_data = record['kinesis']['data']
              decoded_data = base64.b64decode(raw_data).decode('utf-8')
              print(f"处理Kinesis记录: {decoded_data}")
              # 这里添加你的业务逻辑
      elif event_source == 'aws:dynamodb':
          # 处理DynamoDB流变更
          for record in event['Records']:
              change_type = record['eventName']
              old_item = record['dynamodb'].get('OldImage')
              new_item = record['dynamodb'].get('NewImage')
              print(f"DynamoDB变更类型: {change_type}")
              print(f"旧数据: {old_item}")
              print(f"新数据: {new_item}")
              # 这里添加你的业务逻辑
      else:
          print(f"未处理的事件源类型: {event_source}")
      
      return {"statusCode": 200, "body": "事件处理完成"}
  

• 资源与并发考量：当两个流同时触发Lambda时，需要关注函数的并发执行配额。如果两个流的吞吐量都较高，可能需要向AWS申请调高函数的并发限制，避免出现节流（Throttling）情况。另外，每个事件源映射的批量大小、批次窗口等参数可以单独配置，你需要根据各自流的数据量和业务延迟要求来调整这些参数。

内容的提问来源于stack exchange，提问作者Alex Q