ADF 增量复制 Activity 失败,从数据湖中删除部分复制的文件
ADF Delta Copy Activity fails, delete partly copied file from data lake
我有一个每小时增量加载管道,因为我有一个副本 activity 用于将数据从 sql 服务器复制到具有文件夹结构 (YY/MM/DD/table_nameHH) 的数据湖镶木地板格式activity:
复制后 activity 我有 success/failure 程序来更新控件中的记录 table
我需要确保是否有任何副本 activity 在我需要从数据湖中删除部分复制的文件之间失败。如何设置该条件以在我的管道中选择和删除该动态文件。
提前致谢
p.s我对这个工具还很陌生,每天都在学习。
请参考以下步骤:
您可以在 Copy_DimCustomer_AC
活动后面添加一个 If condition:
在If条件表达式中,构建判断Copy_DimCustomer_AC.executionDetails.status
是否等于“Succeeded”的表达式,如果为true,则复制active成功:
@equals(activity('Copy_Dimcustomer_AC').output.executionDetails.status,'Succeeded')
真实活性:
false active: 添加一个delete active删除文件和运行 Log_failure_status_AC
:
HTH.
我有一个每小时增量加载管道,因为我有一个副本 activity 用于将数据从 sql 服务器复制到具有文件夹结构 (YY/MM/DD/table_nameHH) 的数据湖镶木地板格式activity:
复制后 activity 我有 success/failure 程序来更新控件中的记录 table
我需要确保是否有任何副本 activity 在我需要从数据湖中删除部分复制的文件之间失败。如何设置该条件以在我的管道中选择和删除该动态文件。
提前致谢
p.s我对这个工具还很陌生,每天都在学习。
请参考以下步骤:
您可以在 Copy_DimCustomer_AC
活动后面添加一个 If condition:
在If条件表达式中,构建判断Copy_DimCustomer_AC.executionDetails.status
是否等于“Succeeded”的表达式,如果为true,则复制active成功:
@equals(activity('Copy_Dimcustomer_AC').output.executionDetails.status,'Succeeded')
真实活性:
false active: 添加一个delete active删除文件和运行 Log_failure_status_AC
:
HTH.