SearchIndexingBufferedSender Class

A buffered sender for document indexing actions.

Inheritance

azure.search.documents._search_indexing_buffered_sender_base.SearchIndexingBufferedSenderBase

SearchIndexingBufferedSender

azure.search.documents._headers_mixin.HeadersMixin

SearchIndexingBufferedSender

Constructor

SearchIndexingBufferedSender(endpoint: str, index_name: str, credential: AzureKeyCredential | AsyncTokenCredential, **kwargs: Any)

Parameters

Name	Description
endpoint Required	str The URL endpoint of an Azure search service
index_name Required	str The name of the index to connect to
credential Required	AzureKeyCredential or AsyncTokenCredential A credential to authorize search client requests

Keyword-Only Parameters

Name	Description
auto_flush_interval	int how many max seconds if between 2 flushes. This only takes effect when auto_flush is on. Default to 60 seconds.
initial_batch_action_count	int The initial number of actions to group into a batch when tuning the behavior of the sender. The default value is 512.
max_retries_per_action	int The number of times to retry a failed document. The default value is 3.
on_new	callable If it is set, the client will call corresponding methods when there is a new IndexAction added.
on_progress	callable If it is set, the client will call corresponding methods when there is a IndexAction succeeds.
on_error	callable If it is set, the client will call corresponding methods when there is a IndexAction fails.
on_remove	callable If it is set, the client will call corresponding methods when there is a IndexAction removed from the queue (succeeds or fails).
api_version	str The Search API version to use for requests.
audience	str sets the Audience to use for authentication with Azure Active Directory (AAD). The audience is not considered when using a shared key. If audience is not provided, the public cloud audience will be assumed.

Methods

close	Close the session. :return: None :rtype: None
delete_documents	Queue delete documents actions :param documents: A list of documents to delete. :type documents: list[Dict]
flush	Flush the batch. :param int timeout: time out setting. Default is 86400s (one day) :return: True if there are errors. Else False :rtype: bool :raises ~azure.core.exceptions.ServiceResponseTimeoutError:
index_documents	Specify a document operations to perform as a batch. :raises ~azure.search.documents.RequestEntityTooLargeError
merge_documents	Queue merge documents actions :param documents: A list of documents to merge. :type documents: list[dict]
merge_or_upload_documents	Queue merge documents or upload documents actions :param documents: A list of documents to merge or upload. :type documents: list[dict]
upload_documents	Queue upload documents actions. :param documents: A list of documents to upload. :type documents: list[dict]

close

Close the session. :return: None :rtype: None

async close(**kwargs: Any) -> None

delete_documents

Queue delete documents actions :param documents: A list of documents to delete. :type documents: list[Dict]

async delete_documents(documents: List[Dict], **kwargs: Any) -> None

flush

Flush the batch. :param int timeout: time out setting. Default is 86400s (one day) :return: True if there are errors. Else False :rtype: bool :raises ~azure.core.exceptions.ServiceResponseTimeoutError:

async flush(timeout: int = 86400, **kwargs) -> bool

index_documents

Specify a document operations to perform as a batch.

:raises ~azure.search.documents.RequestEntityTooLargeError

async index_documents(batch: IndexDocumentsBatch, **kwargs: Any) -> List[IndexingResult]

Parameters

Name	Description
batch Required	IndexDocumentsBatch A batch of document operations to perform.

Returns

Type	Description
list[IndexingResult]	Indexing result for each action in the batch.

merge_documents

Queue merge documents actions :param documents: A list of documents to merge. :type documents: list[dict]

async merge_documents(documents: List[Dict], **kwargs: Any) -> None

merge_or_upload_documents

Queue merge documents or upload documents actions :param documents: A list of documents to merge or upload. :type documents: list[dict]

async merge_or_upload_documents(documents: List[Dict], **kwargs: Any) -> None

upload_documents

Queue upload documents actions. :param documents: A list of documents to upload. :type documents: list[dict]

async upload_documents(documents: List[Dict], **kwargs: Any) -> None

Attributes

actions

The list of currently index actions in queue to index. :return: The list of currently index actions in queue to index. :rtype: list[IndexAction]