SearchIndexingBufferedSender 클래스

문서 인덱싱 작업을 위한 버퍼링된 보낸 사람입니다.

상속

azure.search.documents._search_indexing_buffered_sender_base.SearchIndexingBufferedSenderBase

SearchIndexingBufferedSender

azure.search.documents._headers_mixin.HeadersMixin

SearchIndexingBufferedSender

생성자

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

매개 변수

endpoint

str

필수

Azure Search 서비스의 URL 엔드포인트

index_name

str

필수

연결할 인덱스의 이름입니다.

credential

AzureKeyCredential 또는 TokenCredential

필수

검색 클라이언트 요청에 권한을 부여하는 자격 증명

auto_flush_interval

int

2개 플러시 사이의 최대 시간(초)입니다. 이는 auto_flush 있는 경우에만 적용됩니다. 기본값은 60초입니다.

initial_batch_action_count

int

보낸 사람의 동작을 튜닝할 때 일괄 처리로 그룹화할 초기 작업 수입니다. 기본값은 512입니다.

max_retries_per_action

int

실패한 문서를 다시 시도할 횟수입니다. 기본값은 3입니다.

on_new

callable

설정된 경우 클라이언트는 새 IndexAction이 추가된 경우 해당 메서드를 호출합니다. 이는 기본 스레드 또는 작업자 스레드에서 호출될 수 있습니다.

on_progress

callable

설정된 경우 IndexAction이 성공하면 클라이언트는 해당 메서드를 호출합니다. 이는 기본 스레드 또는 작업자 스레드에서 호출될 수 있습니다.

on_error

callable

설정된 경우 클라이언트는 IndexAction이 실패할 때 해당 메서드를 호출합니다. 이는 기본 스레드 또는 작업자 스레드에서 호출될 수 있습니다.

on_remove

callable

설정된 경우 클라이언트는 큐에서 제거된 IndexAction이 있을 때 해당 메서드를 호출합니다(성공 또는 실패). 이는 기본 스레드 또는 작업자 스레드에서 호출될 수 있습니다.

api_version

str

요청에 사용할 Search API 버전입니다.

audience

str

는 AAD(Azure Active Directory)를 사용하여 인증에 사용할 대상 그룹을 설정합니다. 공유 키를 사용할 때 대상 그룹은 고려되지 않습니다. 대상 그룹이 제공되지 않으면 퍼블릭 클라우드 대상 그룹이 가정됩니다.

메서드

close	세션을 닫습니다 SearchClient .
delete_documents	큐 삭제 문서 작업
flush	일괄 처리를 플러시합니다.
index_documents	일괄 처리로 수행할 문서 작업을 지정합니다. :발생 시킵니다 RequestEntityTooLargeError
merge_documents	큐 병합 문서 작업
merge_or_upload_documents	문서 병합 또는 문서 업로드 작업 큐
upload_documents	큐 업로드 문서 작업

close

세션을 닫습니다 SearchClient .

close(**kwargs) -> None

delete_documents

큐 삭제 문서 작업

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

매개 변수

documents

list[dict]

필수

삭제할 문서 목록입니다.

flush

일괄 처리를 플러시합니다.

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

매개 변수

timeout

int

필수

시간 제한 설정. 기본값은 86400s(1일)입니다.

반환

True이면 오류가 발생합니다. Else False

반환 형식

bool

예외

azure.core.exceptions.ServiceResponseTimeoutError

index_documents

일괄 처리로 수행할 문서 작업을 지정합니다.

:발생 시킵니다 RequestEntityTooLargeError

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

매개 변수

batch

IndexDocumentsBatch

필수

수행할 문서 작업의 일괄 처리입니다.

반환

일괄 처리의 각 작업의 인덱싱 결과입니다.

반환 형식

list[IndexingResult]

merge_documents

큐 병합 문서 작업

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

매개 변수

documents

list[dict]

필수

병합할 문서 목록입니다.

merge_or_upload_documents

문서 병합 또는 문서 업로드 작업 큐

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

매개 변수

documents

list[dict]

필수

병합하거나 업로드할 문서 목록입니다.

upload_documents

큐 업로드 문서 작업

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

매개 변수

documents

list[dict]

필수

업로드할 문서 목록입니다.

특성

actions

인덱싱할 큐의 현재 인덱스 작업 목록입니다.

반환 형식

list[IndexAction]