ADF - C# 自定义 Activity

Question

我有一个 csv 文件作为输入，我已将其存储在 Azure Blob 存储中。我想从 csv 文件中读取数据，对其执行一些转换，然后将数据存储在 Azure SQL 数据库中。我正在尝试在 Azure 数据工厂中使用 C# 自定义 activity，将 blob 作为输入，将 sql table 作为输出数据集。我正在学习本教程 (https://azure.microsoft.com/en-us/documentation/articles/data-factory-use-custom-activities/#see-also)，但它的输入和输出都是 blob。我能得到一些 sql 数据库的示例代码作为输出吗，因为我不知道该怎么做。谢谢

Answer 1

您只需从链接服务中获取 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 ();

ADF - C# 自定义 Activity

ADF - C # Custom Activity

custom-activity

azure-data-factory