EventDataBatch Sınıf

  • Başvuru

Bir grup olay.

Olayları toplu olarak göndermek, tek tek olayları göndermekten daha yüksek performanslıdır. EventDataBatch, gönderme performansını geliştirmek için izin verilen en büyük EventData boyutu toplu işlemini oluşturmanıza yardımcı olur.

Bayt cinsinden toplu iş boyutu üst sınırına ulaşılana kadar olayları eklemek için add yöntemini kullanın; bu noktada bir ValueError oluşturulur. göndermek için veya zaman uyumsuz EventHubProducerClient send_batch EventHubProducerClient yöntemini kullanın.

EventDataBatch nesnesini doğrudan örneklemek yerine bir EventDataBatch nesnesi oluşturmak için lütfen EventHubProducerClient'ın create_batch yöntemini kullanın.

UYARI: Örnek oluşturulan bir EventDataBatch nesnesinde max_size_in_bytes örnek değişkeninin değerinin güncelleştirilmesi YÜKSEK ORANDA ÖNERILMEZ. Güncelleştirilmiş max_size_in_bytes değeri Event Hubs hizmetinin izin verdiği en büyük olay boyutuyla çakışabilir ve gönderme hatasına neden olabilir.

Devralma
builtins.object
EventDataBatch

Oluşturucu

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

Parametreler

Name Description
max_size_in_bytes
int

EventDataBatch nesnesinin tutabileceği bayt verisi boyutu üst sınırı.

varsayılan değer: None
partition_id
str

Gönderilecek bölüm kimliği.

varsayılan değer: None
partition_key
str

Verilen partition_key, olay verileri hizmet tarafından karar verilen Olay Hub'ının belirli bir bölümüne gönderilir.

varsayılan değer: None

Yöntemler

add

Toplu iş için bir EventData eklemeyi deneyin.

Eklenen bir olayın toplam boyutu, gövdesinin, özelliklerinin vb. toplamıdır. Bu eklenen boyut, toplu iş boyutunun üst sınırı aşması ile sonuçlanırsa , bir ValueError oluşturulur.

add

Toplu iş için bir EventData eklemeyi deneyin.

Eklenen bir olayın toplam boyutu, gövdesinin, özelliklerinin vb. toplamıdır. Bu eklenen boyut, toplu iş boyutunun üst sınırı aşması ile sonuçlanırsa , bir ValueError oluşturulur.

add(event_data: EventData | AmqpAnnotatedMessage) -> None

Parametreler

Name Description
event_data
Gerekli
Union[EventData, AmqpAnnotatedMessage]

Toplu iş için eklenecek EventData.

Döndürülenler

Tür Description
None

Öznitelikler

message

Temel alınan uamqp'yi alın. BatchMessage veya LegacyBatchMessage. Bu kullanım dışıdır ve sonraki bir sürümde kaldırılacaktır.

Döndürülenler

Tür Description
<xref:uamqp.BatchMessage>,
<xref:LegacyBatchMessage>

size_in_bytes

Toplu işlemdeki olayların bayt cinsinden birleşik boyutu.

Döndürülenler

Tür Description
int