需要基于Audit表数据输入运行Pipeline [英] Need to run Pipeline based on Audit table Data Entry

问题描述

你好，



我来自SSIS和SQL工作背景来运行套餐。



我目前的工作任务是在ADF V2中移动和提升SSIS包。



现在在SSIS包中，出现任何数据错误，我们忽略了失败 但在我的审计表中我保持PAckage状态=失败



现在我的要求是如果审计表输入失败它将不会移动到下一步。所以SQL工作我知道如何设置这个东西。



但是在adf我如何设置这样的条件，如果审计表输入失败，请向利益相关方发送电子邮件其他IT将进入下一步并执行该包。

Hello,

I am coming from SSIS and SQL jobs background to run packages.

My current work assignment is to Shift and Lift SSIS packages in ADF V2.

Now in SSIS package , Any Data error comes we are ignoring failures  but in my Audit table I have maintaining PAckage status=Failed

Now my requirement is that If Audit table is having Failed entry It will not move to next step.So in SQL job I know how to set this thing.

But in adf how to I put such condition like , If Audit table is having failed entry send email to Stakeholder else IT will move to next step and execute that package.

推荐答案

您好Aminesh，

Hi Aminesh,

单向这样做是通过使用逻辑应用程序（请阅读此了解用于触发逻辑应用程序的SQL连接器）或azure函数（请
读取此内容以了解如何创建基于SQL的触发器Azure功能）与ADF V2结合。 

One way to do it is by using a logic app (please read this to learn about SQL connector for triggering logic apps) or an azure function(please read this to learn how to create a SQL based trigger for Azure function) in conjunction with ADF V2. 

一旦Audit表（添加了行）发生了变化，您就可以通过调用它的REST API来触发ADF V2管道。要了解更多信息，请参阅

此文档。在管道中，您可以拥有"获取元数据"。读取Audit表的firstRow的活动，并根据该活动触发复制（或其他）活动。

Once there's a change in the Audit table (row added), you can trigger an ADF V2 pipeline run by invoking it's REST API. To read more about it, please refer this doc. In the pipeline, you can have a "Get Metadata" Activity to read the firstRow of the Audit table and based on that, trigger a copy(or other) activity.

希望这会有所帮助。

这篇关于需要基于Audit表数据输入运行Pipeline的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！