Azure Event Hubs Pythonis: AMQP üle WebSocketsi HTTP-puhverserveri kaudu

Edastage Event Hubsi http_proxy sõnastik hostinime ja täisarvulise pordiga, valides samal ajal WebSocketi AMQP-transpordi.

HTTP-puhverserverit kasutava Event Hubsi Pythoni tarbija puhul seadistage kliendi loomisel SDK puhverserveri sõnastik ja WebSocketi transport:

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

Nimeruum, Event Hubi nimi ja mandaat on rakenduse olemasolev teenusekonfiguratsioon. Jätkake selle vastuvõtutagasihelistamistega ja tavapärase kliendi sulgemise elutsükliga.

See sõnastik kirjeldab vahendajat otseselt. See ei ole http/https-sihtkoha skeemide kaart, mille Requests vastu võtab. Avaliku Event Hubsi nimeruumi jaoks, kus avalikud vahendajad on lubatud, pakub HTTP-puhverserverite loend kandidaate kontota hostinime ja pordi väljadele. Lisage võtmed username ja password, kui kavandatud puhverserveri kontot on vaja.

AMQP üle WebSocketsi kasutab teenuse porti 443, samas kui tavaline AMQP-transport kasutab porti 5671. Puhverserver peab siiski lubama tekkivat ühendust Event Hubsi nimeruumi.

Tõendimandaat võib lubade hankimise ajal teha eraldi HTTP-päringuid. Seadistage selle toetatud transport vastavalt vajadusele, kui ka see autentimistee vajab puhverserverit.

Seotud artiklid