【发布时间】:2019-02-05 14:53:51
【问题描述】:
我有一个带有失败输出的查找活动,它执行存储过程活动。存储过程活动记录失败。如何以编程方式获取错误查找活动的名称以及存储过程活动的输入参数中的错误消息?谢谢。
【问题讨论】:
-
您好,如果您认为对您有帮助,可以将其标记为答案吗?非常感谢!
我有一个带有失败输出的查找活动,它执行存储过程活动。存储过程活动记录失败。如何以编程方式获取错误查找活动的名称以及存储过程活动的输入参数中的错误消息?谢谢。
【问题讨论】:
您可以按照示例 sdk 代码 here 从在管道中运行的活动中获取错误消息。
1.运行 Lookup 活动管道。
CreateRunResponse runResponse = client.Pipelines.CreateRunWithHttpMessagesAsync(resourceGroup, dataFactoryName, pipelineName).Result.Body;
Console.WriteLine("Pipeline run ID: " + runResponse.RunId);
2.如果遇到某些问题,请获取错误消息。
List<ActivityRun> activityRuns = client.ActivityRuns.ListByPipelineRun(
resourceGroup, dataFactoryName, runResponse.RunId, DateTime.UtcNow.AddMinutes(-10), DateTime.UtcNow.AddMinutes(10)).ToList();
if (pipelineRun.Status == "Succeeded")
Console.WriteLine(activityRuns.First().Output);
else
Console.WriteLine(activityRuns.First().Error);
3.然后以上述消息为参数运行另一个sp活动管道。
Dictionary<string, object> parameters = new Dictionary<string, object>
{
{ "errorMessage", activityRuns.First().Error}
};
CreateRunResponse runResponse = client.Pipelines.CreateRunWithHttpMessagesAsync(resourceGroup, dataFactoryName, pipelineName, parameters: parameters).Result.Body;
Console.WriteLine("Pipeline run ID: " + runResponse.RunId);
【讨论】: