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();