abatch_iterate#

async langchain_core.utils.aiter.abatch_iterate(size: int, iterable: AsyncIterable[T]) AsyncIterator[list[T]][source]#

用于异步可迭代对象的实用批处理函数。

Parameters:
  • size (int) – 批次的大小。

  • iterable (AsyncIterable[T]) – 要批处理的异步可迭代对象。

Returns:

一个异步迭代器,用于遍历批次。

Return type:

AsyncIterator[列表[T]]