これは絶対に可能です。カスタムADFパイプラインコンポーネントを作成し、IDotNetActivity
インタフェース、より正確な
public IDictionary<string, string> Execute(IEnumerable<LinkedService> linkedServices,
IEnumerable<Dataset> datasets, Activity activity, IActivityLogger logger)
{
//PipelineConfiguration(...) // configure your pipeline/activity
// some code if needed
do
{
BlobResultSegment blobList;
// Get the list of input blobs from the input storage client object.
blobList = prodAzureStorageClient.ListBlobsSegmented($"{fileContainer}/{fileMask_ifAny}",
true, // Use flat blob listing
BlobListingDetails.Metadata,
null, // Max results, null = 5000
continuationToken,
null, // Blob request options
null // Operation context
);
blobs.AddRange(blobList.Results);
continuationToken = blobList.ContinuationToken;
} while (continuationToken != null);
// Read files here and concatenate them by you rules
// Upload concatenated file to Azure Blob Storage
}
挨拶
を実装する必要があります