I have 47 files in ADLS folder. I need to batch process it. Every iteration should process 10 files. So it should have 5 iteration with 10 files for each iteration and last iteration with 47 files. I need to implement this logic in ADF pipeline
I tried to filter using the filter activity but not able to filter based on the number of files
To files with the batches, you need to use multiple activities or increment variables to get the batch of 10 file names.
Follow below steps to achieve your requirements:
@equals(variables('skipinc'), 50)
@variables('skipinc')
@take(skip(variables('files'),variables('skip')),add(variables('skip'),10))
Note: After this step you can take execute pipeline and pass ths variable to that pipeline and process that batch of files
@add(variables('skip'),10 )
.
Output:
For every iteration of until loop it will create a batch of 10 files: