다음을 통해 공유

EventDataBatch 클래스

  • 참조

이벤트의 일괄 처리입니다.

일괄 처리로 이벤트를 보내는 것은 개별 이벤트를 보내는 것보다 성능이 더 높습니다. EventDataBatch를 사용하면 EventData 의 최대 허용 크기 일괄 처리를 만들어 전송 성능을 향상시킬 수 있습니다.

add 메서드를 사용하여 최대 일괄 처리 크기 제한(바이트)에 도달할 때까지 이벤트를 추가합니다. 이때 ValueError가 발생합니다. 의 send_batch 메서드 EventHubProducerClient 또는 비동기를 EventHubProducerClient 사용하여 보냅니다.

EventHubProducerClient의 create_batch 메서드를 사용하여 EventDataBatch 개체를 직접 인스턴스화하는 대신 EventDataBatch 개체를 만듭니다.

경고: 인스턴스화된 EventDataBatch 개체에서 max_size_in_bytes 인스턴스 변수의 값을 업데이트하는 것은 권장되지 않습니다. 업데이트된 max_size_in_bytes 값이 Event Hubs 서비스에서 허용하는 최대 이벤트 크기와 충돌하여 전송 오류가 발생할 수 있습니다.

상속
builtins.object
EventDataBatch

생성자

EventDataBatch(max_size_in_bytes: int | None = None, partition_id: str | None = None, partition_key: str | bytes | None = None, **kwargs: Any)

매개 변수

Name Description
max_size_in_bytes
int

EventDataBatch 개체가 보유할 수 있는 최대 바이트 데이터 크기입니다.

기본값: None
partition_id
str

보낼 특정 파티션 ID입니다.

기본값: None
partition_key
str

지정된 partition_key 사용하여 이벤트 데이터는 서비스에서 결정한 이벤트 허브의 특정 파티션으로 전송됩니다.

기본값: None

메서드

add

일괄 처리에 EventData를 추가해 봅니다.

추가된 이벤트의 총 크기는 본문, 속성 등의 합계입니다. 이 크기가 추가되면 일괄 처리가 최대 일괄 처리 크기를 초과하면 ValueError 가 발생합니다.

add

일괄 처리에 EventData를 추가해 봅니다.

추가된 이벤트의 총 크기는 본문, 속성 등의 합계입니다. 이 크기가 추가되면 일괄 처리가 최대 일괄 처리 크기를 초과하면 ValueError 가 발생합니다.

add(event_data: EventData | AmqpAnnotatedMessage) -> None

매개 변수

Name Description
event_data
필수
Union[EventData, AmqpAnnotatedMessage]

일괄 처리에 추가할 EventData입니다.

반환

형식 Description
None

특성

message

기본 uamqp를 가져옵니다. BatchMessage 또는 LegacyBatchMessage. 이 기능은 더 이상 사용되지 않으며 이후 릴리스에서 제거될 예정입니다.

반환

형식 Description
<xref:uamqp.BatchMessage>,
<xref:LegacyBatchMessage>

size_in_bytes

일괄 처리에 있는 이벤트의 결합된 크기(바이트)입니다.

반환

형식 Description
int