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]], ShardKeyWithFallback]] = None, update_filter: Optional[Union[Filter, Filter]] = None, **kwargs: Any)[source]

Bases: BaseUploader

process(items: Iterable[Any]) → Iterable[bool][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]], ShardKeyWithFallback]], update_filter: Optional[Filter], wait: bool = False) → bool[source]