qdrant_client.uploader.rest_uploader module

class RestBatchUploader(uri: str, collection_name: str, max_retries: int, wait: bool = False, shard_key_selector: Optional[Union[int, str, List[Union[int, str]]]] = None, **kwargs: Any)[source]

Bases: BaseUploader

process(items: Iterable[Any]) → Generator[bool, None, None][source]

classmethod start(collection_name: Optional[str] = None, uri: str = 'http://localhost:6333', max_retries: int = 3, **kwargs: Any) → RestBatchUploader[source]

upload_batch(openapi_client: SyncApis, collection_name: str, batch: Union[tuple, Batch], max_retries: int, shard_key_selector: Optional[Union[int, str, List[Union[int, str]]]], wait: bool = False) → bool[source]