Azure Event Hubs v Pythonu: AMQP přes WebSockets prostřednictvím HTTP proxy

Předejte slovník http_proxy pro Event Hubs s názvem hostitele a celočíselným portem a současně zvolte přenos WebSocket AMQP.

Pro spotřebitele Event Hubs v Pythonu, který používá HTTP proxy, nakonfigurujte při sestavování klienta slovník proxy v SDK a přenos WebSocket:

from azure.eventhub import EventHubConsumerClient, TransportType

client = EventHubConsumerClient(
    fully_qualified_namespace=namespace,
    eventhub_name=eventhub_name,
    consumer_group='$Default',
    credential=credential,
    transport_type=TransportType.AmqpOverWebsocket,
    http_proxy={
        'proxy_hostname': 'proxy.example',
        'proxy_port': 8080,
    },
)

Obor názvů, název Event Hubu a pověření jsou stávající konfigurace služby v aplikaci. Pokračujte jejími zpětnými voláními pro příjem a obvyklým životním cyklem uzavření klienta.

Tento slovník popisuje zprostředkovatele přímo. Není to mapa cílových schémat http/https, kterou přijímá Requests. Pro veřejný obor názvů Event Hubs, kde jsou veřejní zprostředkovatelé povoleni, dodává seznam HTTP proxy kandidáty pro pole názvu hostitele a portu bez účtu. Pokud je vyžadován zamýšlený účet proxy, přidejte klíče username a password.

AMQP přes WebSockets používá port 443 této služby, zatímco běžný přenos AMQP používá 5671. Proxy přesto musí povolit výsledné připojení k oboru názvů Event Hubs.

Pověření tokenu může při získávání tokenů provádět samostatné požadavky HTTP. Pokud tato cesta ověřování také potřebuje proxy, nakonfigurujte podle potřeby jeho podporovaný přenos.

Související články