EventHubProducerClient Třída

Zavřete základní připojení a propojení AMQP klienta producenta.

async close(*, flush: bool = True, **kwargs: Any) -> None

Parametry

Návratový typ

Výjimky

Pokud došlo k chybě při vyprazdňování vyrovnávací paměti, pokud je vyprázdnění nastaveno na true nebo ukončení podkladových připojení AMQP v režimu vyrovnávací paměti.

Příklady

Zavřete obslužnou rutinu.

   import os
   from azure.eventhub.aio import EventHubProducerClient
   from azure.eventhub import EventData

   event_hub_connection_str = os.environ['EVENT_HUB_CONN_STR']
   eventhub_name = os.environ['EVENT_HUB_NAME']

   producer = EventHubProducerClient.from_connection_string(
       conn_str=event_hub_connection_str,
       eventhub_name=eventhub_name  # EventHub name should be specified if it doesn't show up in connection string.
   )
   try:
       event_data_batch = await producer.create_batch()
       while True:
           try:
               event_data_batch.add(EventData('Message inside EventBatchData'))
           except ValueError:
               # The EventDataBatch object reaches its max_size.
               # You can send the full EventDataBatch object and create a new one here.
               break
       await producer.send_batch(event_data_batch)
   finally:
       # Close down the producer handler.
       await producer.close()

Vytvořte objekt EventDataBatch s maximální velikostí veškerého obsahu, který je omezen max_size_in_bytes.

Max_size_in_bytes by neměla být větší než maximální povolená velikost zprávy definovaná službou.

async create_batch(*, partition_id: str | None = None, partition_key: str | None = None, max_size_in_bytes: int | None = None) -> EventDataBatch

Návratový typ

Výjimky

Pokud došlo k chybě při vyprazdňování vyrovnávací paměti, pokud je vyprázdnění nastaveno na true nebo ukončení podkladových připojení AMQP v režimu vyrovnávací paměti.

Příklady

Vytvoření objektu EventDataBatch v omezené velikosti

       from azure.eventhub import EventData
       event_data_batch = await producer.create_batch()
       while True:
           try:
               event_data_batch.add(EventData('Message inside EventBatchData'))
           except ValueError:
               # The EventDataBatch object reaches its max_size.
               # You can send the full EventDataBatch object and create a new one here.
               break

Pouze režim vyrovnávací paměti. Vyprázdnění událostí ve vyrovnávací paměti, které se mají okamžitě odeslat, pokud klient pracuje v režimu vyrovnávací paměti.

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

Parametry

Návratový typ

Výjimky

Pokud se producentovi nepodaří vyprázdnit vyrovnávací paměť v rámci daného časového limitu v režimu vyrovnávací paměti.

Vytvořte EventHubProducerClient z připojovací řetězec.

from_connection_string(conn_str: str, *, eventhub_name: str | None = None, buffered_mode: bool = False, on_error: Callable[[List[EventData | AmqpAnnotatedMessage], str | None, Exception], Awaitable[None]] | None = None, on_success: Callable[[List[EventData | AmqpAnnotatedMessage], str | None], Awaitable[None]] | None = None, max_buffer_length: int | None = None, max_wait_time: float | None = None, logging_enable: bool = False, http_proxy: Dict[str, str | int] | None = None, auth_timeout: float = 60, user_agent: str | None = None, retry_total: int = 3, transport_type: TransportType = TransportType.Amqp, **kwargs: Any) -> EventHubProducerClient

Parametry

Návratový typ

Výjimky

Pokud došlo k chybě při vyprazdňování vyrovnávací paměti, pokud je vyprázdnění nastaveno na true nebo ukončení podkladových připojení AMQP v režimu vyrovnávací paměti.

Příklady

Z připojovací řetězec vytvořte novou instanci EventHubProducerClient.

   import os
   from azure.eventhub.aio import EventHubProducerClient
   event_hub_connection_str = os.environ['EVENT_HUB_CONN_STR']
   eventhub_name = os.environ['EVENT_HUB_NAME']
   producer = EventHubProducerClient.from_connection_string(
       conn_str=event_hub_connection_str,
       eventhub_name=eventhub_name  # EventHub name should be specified if it doesn't show up in connection string.
   )

Počet událostí, které jsou v vyrovnávací paměti a čekají na publikování pro daný oddíl. Vrátí hodnotu None v režimu bez vyrovnávací paměti. POZNÁMKA: Vyrovnávací paměť událostí se zpracovává v korutině na pozadí, proto počet událostí ve vyrovnávací paměti hlášený tímto rozhraním API by měl být považován pouze za aproximaci a doporučuje se pouze pro použití při ladění. Pro ID oddílu, který nemá žádné události ve vyrovnávací paměti, se vrátí hodnota 0 bez ohledu na to, jestli TOTO ID oddílu v centru událostí skutečně existuje.

get_buffered_event_count(partition_id: str) -> int | None

Parametry

Návratový typ

Výjimky

Pokud došlo k chybě při vyprazdňování vyrovnávací paměti, pokud je vyprázdnění nastaveno na true nebo ukončení podkladových připojení AMQP v režimu vyrovnávací paměti.

Získejte vlastnosti centra událostí.

Mezi klíče ve vráceném slovníku patří:

• eventhub_name (str)

• created_at (UTC datetime.datetime)

• partition_ids (list[str])

async get_eventhub_properties() -> Dict[str, Any]

Návraty

Slovník obsahující informace o centru událostí.

Návratový typ

Výjimky

Získejte ID oddílů centra událostí.

async get_partition_ids() -> List[str]

Návraty

Seznam ID oddílů.

Návratový typ

Výjimky

Získá vlastnosti zadaného oddílu.

Mezi klíče ve slovníku vlastností patří:

• eventhub_name (str)

• id (str)

• beginning_sequence_number (int)

• last_enqueued_sequence_number (int)

• last_enqueued_offset (str)

• last_enqueued_time_utc (UTC datetime.datetime)

• is_empty (bool)

async get_partition_properties(partition_id: str) -> Dict[str, Any]

Parametry

Návraty

Dict vlastností oddílu.

Návratový typ

Výjimky

Odešle dávku dat událostí. Ve výchozím nastavení bude metoda blokovat, dokud nedojde k potvrzení nebo dokud nevypadne časový limit operace. Pokud je EventHubProducerClient nakonfigurovaný tak, aby běžel v režimu vyrovnávací paměti, metoda zařadí události do místní vyrovnávací paměti a vrátí je. Producent provede automatické odesílání na pozadí.

Pokud je buffered_mode False, on_error zpětné volání je volitelné a chyby se budou zpracovávat následujícím způsobem:

• Pokud se během vytváření instancí klienta producenta předá zpětné volání on_error ,

  pak se informace o chybě předají zpětnému volání on_error , které se pak zavolá.

• Pokud se během vytváření instancí klienta nepředá zpětné volání on_error,

  pak bude ve výchozím nastavení vyvolána chyba.

Pokud má buffered_mode hodnotu True, vyžaduje se on_error zpětné volání a chyby se budou zpracovávat následujícím způsobem:

• Pokud se událostem nepodaří vytvořit frontu v daném časovém limitu, bude přímo vyvolána chyba.

• Pokud se události po úspěšném zařazení do fronty nepodaří odeslat, bude volána zpětná volání on_error .

V režimu vyrovnávací paměti zůstane odeslání dávky nedotčené a odesláno jako jedna jednotka. Uspořádání dávky nebude přeuspořádané. To může vést k neefektivitě odesílání událostí.

Pokud odesíláte konečný seznam EventData nebo AmqpAnnotatedMessage a víte, že je v limitu velikosti rámce centra událostí, můžete je poslat s send_batch voláním. V opačném případě použijte create_batch k vytvoření EventDataBatch a přidejte buď EventData nebo AmqpAnnotatedMessage do dávky jeden po druhém až do limitu velikosti, a pak voláním této metody odešlete dávku.

async send_batch(event_data_batch: EventDataBatch | List[EventData | AmqpAnnotatedMessage], **kwargs: Any) -> None

Parametry

Návratový typ

Výjimky

Pokud hodnota určená parametrem časového limitu uplynou před událostí může být odeslána v režimu bez vyrovnávací paměti nebo události mohou být zařazení do vyrovnávací paměti v režimu vyrovnávací paměti.

Příklady

Asynchronně odesílá data událostí.

       async with producer:
           event_data_batch = await producer.create_batch()
           while True:
               try:
                   event_data_batch.add(EventData('Message inside EventBatchData'))
               except ValueError:
                   # The EventDataBatch object reaches its max_size.
                   # You can send the full EventDataBatch object and create a new one here.
                   break
           await producer.send_batch(event_data_batch)

Odešle data události. Ve výchozím nastavení bude metoda blokovat, dokud nedojde k potvrzení nebo dokud nevypadne časový limit operace. Pokud je EventHubProducerClient nakonfigurovaný tak, aby běžel v režimu vyrovnávací paměti, metoda zařadí událost do místní vyrovnávací paměti a vrátí ji. Producent provede automatické dávkování a odeslání na pozadí.

Pokud je buffered_mode false, on_error zpětné volání je volitelné a chyby se budou zpracovávat takto: * Pokud se během vytváření instance klienta producenta předá zpětné volání on_error ,

       then error information will be passed to the *on_error* callback, which will then be called.

  * If an *on_error* callback is not passed in during client instantiation,

       then the error will be raised by default.

Pokud má buffered_mode hodnotu True, vyžaduje se on_error zpětné volání a chyby se budou zpracovávat následujícím způsobem: * Pokud se událostem nepodaří vytvořit frontu v daném časovém limitu, bude přímo vyvolána chyba.

  * If events fail to send after enqueuing successfully, the *on_error* callback will be called.

async send_event(event_data: EventData | AmqpAnnotatedMessage, **kwargs: Any) -> None

Parametry

Návratový typ

Výjimky

Pokud hodnota určená parametrem časového limitu uplynou před odesláním události v režimu bez vyrovnávací paměti nebo události nelze zařadit do vyrovnávací paměti v režimu vyrovnávací paměti.

Celkový počet událostí, které jsou aktuálně ve všech oddílech ve vyrovnávací paměti a čekají na publikování. Vrátí hodnotu None v režimu bez vyrovnávací paměti. POZNÁMKA: Vyrovnávací paměť událostí se zpracovává v korutině na pozadí, proto počet událostí ve vyrovnávací paměti hlášený tímto rozhraním API by měl být považován pouze za aproximaci a doporučuje se pouze pro použití při ladění.

Návratový typ