我有100个表,我想经常将其复制到另一个存储帐户。副本结束后,我想删除源表。我能够使用ADF复制活动将表中的实体复制到另一个存储帐户。但无法找到成功复制后删除源表的方法。
我正在使用DataFactory .NET API创建管道,数据集等。我认为自定义活动是解决方案,但不确定如何通过API插入管道?
任何代码示例或建议都得到高度赞赏。
我们可以通过自定义活动来做到这一点。
,但不确定如何通过API插入管道?
我们可以使用创建或更新管道API来创建或更新管道API。
我们可以从本教程中的Azure数据中获取有关如何在Azure数据中使用自定义活动的更多信息。
以下是来自教程的摘要。
1.创建自定义活动.NET类库项目实现IDOTNETACTIVITY接口
2.发出Windows Explorer,并导航到bin debug或bin Release文件夹
3.将Bin Release文件夹下的所有文件汇总,然后上传到Azure Storage CustomActivityContainer
4.创建Azure存储链接服务
5.创建Azure批处理链接服务
我们可以使用创建或更新管道API来创建使用自定义活动的管道
{
"name": "ADFTutorialPipelineCustom",
"properties": {
"description": "Use custom activity",
"activities": [
{
"Name": "MyDotNetActivity",
"Type": "DotNetActivity",
"Inputs": [
{
"Name": "InputDataset"
}
],
"Outputs": [
{
"Name": "OutputDataset"
}
],
"LinkedServiceName": "AzureBatchLinkedService",
"typeProperties": {
"AssemblyName": "MyDotNetActivity.dll",
"EntryPoint": "MyDotNetActivityNS.MyDotNetActivity",
"PackageLinkedService": "AzureStorageLinkedService",
"PackageFile": "customactivitycontainer/MyDotNetActivity.zip",
"extendedProperties": {
"SliceStart": "$$Text.Format('{0:yyyyMMddHH-mm}', Time.AddMinutes(SliceStart, 0))"
}
},
"Policy": {
"Concurrency": 2,
"ExecutionPriorityOrder": "OldestFirst",
"Retry": 3,
"Timeout": "00:30:00",
"Delay": "00:00:00"
}
}
],
"start": "2016-11-16T00:00:00Z",
"end": "2016-11-16T05:00:00Z",
"isPaused": false
}
}
关于如何操作Azure存储表,请参阅文档。