ADF - C#自定义活动

问题描述:

我有一个csv文件作为我存储在Azure Blob存储中的输入。我想从csv文件读取数据,对其执行一些转换,然后将数据存储在Azure SQL数据库中。我正尝试在Azure数据工厂中使用具有blob作为输入和sql表作为输出数据集的C#自定义活动。我正在学习本教程(https://azure.microsoft.com/en-us/documentation/articles/data-factory-use-custom-activities/#see-also),但它的输入和输出均为blob。我可以得到一些示例代码为sql数据库作为输出,因为我无法弄清楚如何做到这一点。谢谢ADF - C#自定义活动

你只需要从链接的服务中获取你的Azure SQL数据库的连接字符串,然后你可以与数据库交谈。试试这个示例代码:

AzureSqlDatabaseLinkedService sqlInputLinkedService; 
AzureSqlTableDataset sqlInputLocation; 

Dataset sqlInputDataset = datasets.Where(dataset => dataset.Name == "<Dataset Name>").First(); 
sqlInputLocation = sqlInputDataset.Properties.TypeProperties as AzureSqlTableDataset; 

sqlInputLinkedService = linkedServices.Where (
        linkedService => 
        linkedService.Name == 
        sqlInputDataset.Properties.LinkedServiceName).First().Properties.TypeProperties 
        as AzureSqlDatabaseLinkedService; 

SqlConnection connection = new SqlConnection(sqlInputLinkedService.ConnectionString); 
connection.Open();