qdrant_client.parallel_processor 模块

class ParallelWorkerPool(num_workers: int, worker: Type[Worker], start_method: Optional[str] = None, max_internal_batch_size: int = 200)

基类: object

check_worker_health() → None

检查是否有任何 worker 进程意外终止

join() → None

join_or_terminate(timeout: Optional[int] = 1) → None

紧急关闭 @param timeout: @return

ordered_map(stream: Iterable[Any], *args: Any, **kwargs: Any) → Iterable[Any]

semi_ordered_map(stream: Iterable[Any], *args: Any, **kwargs: Any) → Iterable[Any]

start(**kwargs: Any) → None

unordered_map(stream: Iterable[Any], *args: Any, **kwargs: Any) → Iterable[Any]

class QueueSignals(value)

基类: str, Enum

一个枚举.

confirm = 'confirm'

error = 'error'

stop = 'stop'

class Worker

基类: object

process(items: Iterable[Any]) → Iterable[Any]

classmethod start(*args: Any, **kwargs: Any) → Worker