Azure Event Hubs w Pythonie: AMQP przez WebSockets za pośrednictwem proxy HTTP

Przekaż słownik http_proxy usługi Event Hubs z nazwą hosta i całkowitym numerem portu, wybierając jednocześnie transport WebSocket AMQP.

Dla konsumenta usługi Event Hubs w Pythonie, który korzysta z proxy HTTP, skonfiguruj słownik proxy zestawu SDK i transport WebSocket podczas tworzenia klienta:

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,
    },
)

Przestrzeń nazw, nazwa centrum Event Hub i poświadczenie to istniejąca konfiguracja usługi w aplikacji. Kontynuuj z jej wywołaniami zwrotnymi odbioru i zwykłym cyklem życia zamykania klienta.

Ten słownik opisuje pośrednika bezpośrednio. To nie jest mapa schematów docelowych http/https akceptowana przez bibliotekę Requests. Dla publicznej przestrzeni nazw Event Hubs, w której dozwolone są publiczne pośredniki, lista proxy HTTP dostarcza kandydatów do pól nazwy hosta i portu bez konta. Dodaj klucze username i password, jeśli wymagane jest zamierzone konto proxy.

AMQP przez WebSockets wykorzystuje port 443 usługi, natomiast zwykły transport AMQP wykorzystuje port 5671. Proxy nadal musi zezwalać na powstałe połączenie z przestrzenią nazw Event Hubs.

Poświadczenie tokenu może wykonywać osobne żądania HTTP podczas uzyskiwania tokenów. Skonfiguruj obsługiwany przez nie transport w razie potrzeby, gdy ta ścieżka uwierzytelniania również wymaga proxy.

Powiązane artykuły