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

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

Za Event Hubs potrošača u Pythonu koji koristi HTTP proksi, konfigurirajte proksi 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 proksija nudi kandidate za polja naziva hosta i porta bez računa. Dodajte ključeve username i password ako je potreban predviđeni proksi račun.

AMQP preko WebSocketa koristi port 443 te usluge, dok obični AMQP transport koristi 5671. Proksi 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 proksi.

Povezani članci