Azure新手求助：如何用C#获取管道最新Activity RunID（无需触发实例）

嗨，我来帮你搞定这个需求！要在不触发管道的前提下，用C#获取Azure Data Factory（ADF）中指定管道的最新Activity RunID，你可以借助ADF的.NET SDK来查询已有的运行历史记录。下面是具体的实现方案：

首先，你需要在项目中安装ADF的.NET管理SDK包，推荐使用最新的Azure.ResourceManager.DataFactory（基于Azure Resource Manager的新SDK，比旧版更简洁安全）：

Install-Package Azure.ResourceManager.DataFactory

或者用.NET CLI：

dotnet add package Azure.ResourceManager.DataFactory

下面的代码会先查询指定管道的最新一次运行记录，再从该运行中获取对应的最新Activity RunID：

using Azure;
using Azure.Identity;
using Azure.ResourceManager.DataFactory;
using Azure.ResourceManager.DataFactory.Models;
using System;
using System.Linq;
using System.Threading.Tasks;

class AdfActivityRunIdFetcher
{
    static async Task Main(string[] args)
    {
        // 替换成你的ADF资源信息
        string subscriptionId = "你的Azure订阅ID";
        string resourceGroupName = "资源组名称";
        string dataFactoryName = "数据工厂名称";
        string targetPipelineName = "你要查询的管道名称";

        // 初始化ADF客户端（用DefaultAzureCredential自动处理身份验证）
        var credential = new DefaultAzureCredential();
        var adfClient = new DataFactoryManagementClient(credential)
        {
            SubscriptionId = subscriptionId
        };

        try
        {
            // 1. 查询指定管道的最新运行记录（时间范围设为最近1个月，可按需调整）
            var pipelineRunFilter = new RunFilterParameters(
                startTime: DateTime.UtcNow.AddMonths(-1),
                endTime: DateTime.UtcNow
            );
            var pipelineRuns = await adfClient.PipelineRuns.QueryByFactoryAsync(
                resourceGroupName,
                dataFactoryName,
                pipelineRunFilter
            );

            // 筛选出目标管道的运行记录，并按更新时间倒序取第一条
            var latestPipelineRun = pipelineRuns.Value
                .Where(run => run.PipelineName.Equals(targetPipelineName, StringComparison.OrdinalIgnoreCase))
                .OrderByDescending(run => run.LastUpdated)
                .FirstOrDefault();

            if (latestPipelineRun == null)
            {
                Console.WriteLine("该管道暂无任何运行记录，请先触发一次管道运行后再尝试");
                return;
            }

            // 2. 查询该管道运行对应的所有Activity运行记录
            var activityRunFilter = new RunFilterParameters(
                startTime: latestPipelineRun.StartTime.Value,
                endTime: latestPipelineRun.EndTime.Value
            );
            var activityRuns = await adfClient.ActivityRuns.QueryByPipelineRunAsync(
                resourceGroupName,
                dataFactoryName,
                latestPipelineRun.RunId,
                activityRunFilter
            );

            // 取最新的Activity RunID（如果需要特定Activity的ID，可加Where(run => run.ActivityName == "目标活动名")）
            var latestActivityRun = activityRuns.Value
                .OrderByDescending(run => run.LastUpdated)
                .FirstOrDefault();

            if (latestActivityRun != null)
            {
                Console.WriteLine($"找到最新Activity RunID: {latestActivityRun.RunId}");
            }
            else
            {
                Console.WriteLine("该管道运行未关联任何Activity记录");
            }
        }
        catch (Exception ex)
        {
            Console.WriteLine($"查询过程中出现错误: {ex.Message}");
        }
    }
}

• 身份验证：DefaultAzureCredential会自动适配本地开发（Azure CLI、Visual Studio登录）和生产环境（托管身份、服务主体）的身份验证方式，无需硬编码密钥，更安全。
• 时间范围：查询Pipeline运行时设置了最近1个月的时间范围，你可以根据实际需求调整（比如改成最近7天），避免查询过多历史数据影响性能。
• 特定Activity筛选：如果你的管道包含多个Activity，且只需要某个特定Activity的RunID，只需在查询ActivityRuns时添加Where(run => run.ActivityName == "你的活动名称")条件即可。

• 确保执行代码的身份（本地用户或托管身份）拥有ADF的Data Factory Reader或Data Factory Contributor权限，否则会出现权限不足的错误。
• 如果目标管道从未运行过，代码会提示无运行记录，此时需要先手动触发一次管道运行才能查询到结果。

内容的提问来源于stack exchange，提问作者Chaithanya