c# - 如何从 C# 代码调用 Azure 数据工厂管道？

Question

我需要一些想法来从 C# 代码调用 ADF（Azure 数据工厂）作业。如果您可以分享一些实现此功能的示例，那将非常有帮助。

感谢您查看我的帖子。

Answer 1

安装最新版本的Microsoft.Azure.Management.DataFactoryNuGet 包。然后您可以像这样触发 ADF 管道：

private DataFactoryManagementClient CreateClient(string subscriptionId, string tenantId)
    {
        // AzureServiceTokenProvider uses developer credentials when running locally
        // and uses managed identity when deployed to Azure.
        // If getting an exception when running locally, run "az login" command in Azure CLI
        var provider = new AzureServiceTokenProvider();
        var token = provider.GetAccessTokenAsync("https://management.azure.com", tenantId).Result;
        ServiceClientCredentials credentials = new TokenCredentials(token);

        DataFactoryManagementClient client = new DataFactoryManagementClient(credentials);
        client.SubscriptionId = subscriptionId;
        return client;
    }

    public async Task<string> TriggerPipeline(string pipelineName, IDictionary<string, object> parameters)
    {
        var run = await client.Pipelines.CreateRunWithHttpMessagesAsync(resourceGroupName, dataFactoryName, pipelineName, parameters: parameters);
        return run.Body.RunId;
    }