IngestionPipeline<T>.ProcessAsync Метод
Определение
Важно!
Некоторые сведения относятся к предварительной версии продукта, в которую до выпуска могут быть внесены существенные изменения. Майкрософт не предоставляет никаких гарантий, явных или подразумеваемых, относительно приведенных здесь сведений.
Перегрузки
| Имя | Описание |
|---|---|
| ProcessAsync(IEnumerable<FileInfo>, CancellationToken) |
Обрабатывает указанные файлы. |
| ProcessAsync(DirectoryInfo, String, SearchOption, CancellationToken) |
Обрабатывает все файлы в указанном каталоге, соответствующий заданному шаблону поиска и параметру. |
ProcessAsync(IEnumerable<FileInfo>, CancellationToken)
- Исходный код:
- IngestionPipeline.cs
Обрабатывает указанные файлы.
public System.Collections.Generic.IAsyncEnumerable<Microsoft.Extensions.DataIngestion.IngestionResult> ProcessAsync(System.Collections.Generic.IEnumerable<System.IO.FileInfo> files, System.Threading.CancellationToken cancellationToken = default);
member this.ProcessAsync : seq<System.IO.FileInfo> * System.Threading.CancellationToken -> System.Collections.Generic.IAsyncEnumerable<Microsoft.Extensions.DataIngestion.IngestionResult>
Public Function ProcessAsync (files As IEnumerable(Of FileInfo), Optional cancellationToken As CancellationToken = Nothing) As IAsyncEnumerable(Of IngestionResult)
Параметры
- files
- IEnumerable<FileInfo>
Коллекция файлов для обработки.
- cancellationToken
- CancellationToken
Маркер отмены для операции.
Возвращаемое значение
Задача, представляющая асинхронную операцию.
Применяется к
ProcessAsync(DirectoryInfo, String, SearchOption, CancellationToken)
- Исходный код:
- IngestionPipeline.cs
Обрабатывает все файлы в указанном каталоге, соответствующий заданному шаблону поиска и параметру.
public System.Collections.Generic.IAsyncEnumerable<Microsoft.Extensions.DataIngestion.IngestionResult> ProcessAsync(System.IO.DirectoryInfo directory, string searchPattern = "*.*", System.IO.SearchOption searchOption = System.IO.SearchOption.TopDirectoryOnly, System.Threading.CancellationToken cancellationToken = default);
member this.ProcessAsync : System.IO.DirectoryInfo * string * System.IO.SearchOption * System.Threading.CancellationToken -> System.Collections.Generic.IAsyncEnumerable<Microsoft.Extensions.DataIngestion.IngestionResult>
Public Function ProcessAsync (directory As DirectoryInfo, Optional searchPattern As String = "*.*", Optional searchOption As SearchOption = System.IO.SearchOption.TopDirectoryOnly, Optional cancellationToken As CancellationToken = Nothing) As IAsyncEnumerable(Of IngestionResult)
Параметры
- directory
- DirectoryInfo
Каталог для обработки.
- searchPattern
- String
Шаблон поиска для выбора файла.
- searchOption
- SearchOption
Параметр поиска для обхода каталога.
- cancellationToken
- CancellationToken
Маркер отмены для операции.
Возвращаемое значение
Задача, представляющая асинхронную операцию.