Azure Event Hubs u Pythonu: AMQP preko WebSocketa kroz HTTP proxy

Proslijedite Event Hubs rječnik http_proxy s imenom hosta i cjelobrojnim portom dok birate WebSocket AMQP transport.

Za Event Hubs potrošač u Pythonu koji koristi HTTP proxy, konfigurirajte proxy rječnik SDK-a i WebSocket transport pri izgradnji klijenta:

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

Namespace, naziv Event Huba i vjerodajnica postojeća su konfiguracija usluge u aplikaciji. Nastavite s njezinim povratnim pozivima za primanje i uobičajenim životnim ciklusom zatvaranja klijenta.

Ovaj rječnik izravno opisuje posrednika. To nije karta odredišnih shema http/https koju prihvaća Requests. Za javni Event Hubs namespace u kojem su javni posrednici dopušteni, popis HTTP proxyja nudi kandidate za polja naziva hosta i porta bez računa. Dodajte ključeve username i password ako je potreban predviđeni proxy račun.

AMQP preko WebSocketa koristi port 443 te usluge, dok obični AMQP transport koristi 5671. Proxy ipak mora dopustiti nastalu vezu prema Event Hubs namespaceu.

Vjerodajnica tokena može tijekom dobivanja tokena slati zasebne HTTP zahtjeve. Konfigurirajte njezin podržani transport prema potrebi kada i taj put provjere autentičnosti treba proxy.

Povezani članci