如果你知道目标夹和目标夹的名单,那么你就可以尝试以下办法。
www.un.org/Depts/DGACM/index_spanish.htm 这些是我的抽样投入文件:。
sourcecon
folder
fileA-20240201.txt
fileA-20240311.txt
fileB-20230201.txt
fileB-20240302.txt
fileC-20230201.txt
fileC-20240310.txt
First create an array variable with letters ["A","B","C",..<till required folders>]. Give this array to a For-Each activity.
建立源数据集和目标数据集。 在目标数据集中,设定了直线参数 倍数——名称,并给出如下数据集的倍数路径。
在路旁边,进行复印活动,并提供生成的来源和汇数据集。 在来文方中,使用野生卡路标如下:file@{item()}*。
在计票中,将数据集参数的“代码”改为“参照标准”。
管道和所有所需档案都将抄送下文等各文件夹。
http://www.ohchr.org。
www.un.org/Depts/DGACM/index_spanish.htm 在目标夹中创建的文件:
www.un.org/Depts/DGACM/index_spanish.htm 我的管道JSON:
{
"name": "pipeline1",
"properties": {
"activities": [
{
"name": "ForEach1",
"type": "ForEach",
"dependsOn": [],
"userProperties": [],
"typeProperties": {
"items": {
"value": "@createArray( A , B , C )",
"type": "Expression"
},
"isSequential": true,
"activities": [
{
"name": "Copy data1",
"type": "Copy",
"dependsOn": [],
"policy": {
"timeout": "0.12:00:00",
"retry": 0,
"retryIntervalInSeconds": 30,
"secureOutput": false,
"secureInput": false
},
"userProperties": [],
"typeProperties": {
"source": {
"type": "DelimitedTextSource",
"storeSettings": {
"type": "AzureBlobFSReadSettings",
"recursive": true,
"wildcardFolderPath": "folder",
"wildcardFileName": {
"value": "file@{item()}*",
"type": "Expression"
},
"enablePartitionDiscovery": false
},
"formatSettings": {
"type": "DelimitedTextReadSettings"
}
},
"sink": {
"type": "DelimitedTextSink",
"storeSettings": {
"type": "AzureBlobFSWriteSettings"
},
"formatSettings": {
"type": "DelimitedTextWriteSettings",
"quoteAllText": true,
"fileExtension": ".txt"
}
},
"enableStaging": false,
"translator": {
"type": "TabularTranslator",
"typeConversion": true,
"typeConversionSettings": {
"allowDataTruncation": true,
"treatBooleanAsNumber": false
}
}
},
"inputs": [
{
"referenceName": "sourcefiles",
"type": "DatasetReference"
}
],
"outputs": [
{
"referenceName": "targetfiles",
"type": "DatasetReference",
"parameters": {
"folder_name": {
"value": "Folder_@{item()}",
"type": "Expression"
}
}
}
]
}
]
}
}
],
"annotations": [],
"lastPublishTime": "2024-03-11T13:35:47Z"
},
"type": "Microsoft.DataFactory/factories/pipelines"
}
