1

谁能解释如何通过 AWS Lambda 执行使用源参数多次激活 AWS Data Pipeline。

目前，第一个处理激活管道，但随后任何后续激活都会失败，有或没有消息（取决于激活参数）

完整的处理循环是将数据移动到 S3，然后启动 DataPipeline 将数据迁移到 Redshift。

    Example 1: aws datapipeline activate-pipeline --pipeline-id {pipelineid}
    Accepts command but will not execute on previously run pipeline


    Example 2: aws datapipeline activate-pipeline --pipeline-id {pipelineid} --end-timestamp, 2015-07-08T00:00:00Z 
    Error: Unknown options: --end-timestamp, 2015-07-08T00:00:00Z 


  Example 3: aws datapipeline activate-pipeline --pipeline-id {pipelineid} --start-timestamp, 2015-07-08T00:00:00Z     
A client error (InvalidRequestException) occured when calling the ActivatePipeline operation: startTimestamp shoudl not be later than any Schedule EndDateTime in the pipeline)

此摘录摘自 AWS 文档：

要激活已完成的管道，请修改管道的结束日期，然后将其激活。

AWS 文档参考

4

2 回答 2

1 
aws datapipeline activate-pipeline --pipeline-id {pipelineid} --start-timestamp 2015-10-15T14:15:18Z
  • {pipelineid}是你的df-xxxxx。
  • 2015-10-15T14:15:18Z是第一次开始运行管道的时间。（只是一个例子）

我们以这种方式在产品中使用并且工作完美，我们可以运行任何完成的数据管道。

于 2015-10-15T19:02:56.273 回答
0

您的管道定义应在计划中定义 endTime。您需要编辑定义以将其更改为在 startDateTime 之后。

--end-timestamp 不是有效参数

于 2015-07-07T19:12:41.820 回答