通过数据管道向Redshift存储错误消息

Question

我试图通过数据管道在Redshift群集中运行SQL活动。在SQL活动之后，几乎没有日志需要以红移的形式写入表[例如受影响的行数，错误消息（如果有的话）]。

要求： 如果SQL活动成功完成，所提到的表将与“错误”一栏为空， 否则如果SQL活动的任何错误失败所写的，特定的错误消息是需要被更新成Redshift表中的'error'列。

我们可以通过管道实现吗？如果是的话，我们如何能做到这一点？

谢谢， Ravi。

Answer 1

不幸的是，你不能直接用DataPipeline中的SqlActivity来做到这一点。解决的办法是编写一个java程序（或任何可执行文件），它可以做你想做的事情，并使用ShellCommandActivity通过Datapipeline进行安排。