0
  1. 我们有一个 AWS 数据管道,可以将数据从 S3 复制到 Redshift ( RedshiftCopyActivity)。
  2. 我们希望在复制完成后调用 Lambda 函数。

到目前为止我的理解是:

  1. Amazon Event Bus 是处理事件和调用函数的推荐方式
  2. Data Pipeline 不会直接引发事件,但会触发 CloudTrail API 调用

CloudTrail + Event Bridge 页面中有一行:“如果要自定义事件模式,请选择 Edit,进行更改,然后选择 Save。”

是否有关于如何编写此规则以匹配特定数据管道 IDRedshiftCopyActivity和“已完成”状态的任何详细信息?

或者如果有更简单的方法来实现这一点,我欢迎它,谢谢。

4

1 回答 1

1

实际上,出于某种原因,我在 EventBridge 服务上找不到任何有关 AWS Data Pipeline 事件的文档或示例事件。

但是,我建议您执行以下操作:

  1. 为 AWS Pipeline 服务在 EventBridge 服务上创建规则。
  2. 选择适当的详细信息(AWS、数据管道、所有事件)

拥有它后,将其连接到 Lambda 并记录您收到的调用和事件。

然后,您实际上可以有一些不同事件的示例,并开发适当的逻辑来处理所需的事件。

此外,稍后,您可以更改规则中的事件模式(在 EventBridge 服务中),因此您将仅在特定事件上调用 Lambda。

在此处输入图像描述

于 2020-12-07T09:37:15.427 回答