Azure Event Hubs në Python: AMQP mbi WebSockets përmes një proxy HTTP

Kaloni fjalorin http_proxy të Event Hubs me emrin e hostit dhe portën numër të plotë, duke zgjedhur transportin WebSocket AMQP.

Për një konsumator Event Hubs në Python që përdor një proxy HTTP, konfiguroni fjalorin e proxy-t të SDK-së dhe transportin WebSocket kur ndërtohet klienti:

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

Hapësira e emrave, emri i Event Hub dhe kredenciali janë konfigurimi ekzistues i shërbimit në aplikacion. Vazhdoni me kthimet e tij të marrjes dhe ciklin e zakonshëm të jetës së mbylljes së klientit.

Ky fjalor e përshkruan ndërmjetësin drejtpërdrejt. Nuk është harta e skemave të destinacionit http/https që pranon Requests. Për një hapësirë emrash publike Event Hubs ku lejohen ndërmjetësit publikë, lista e proxy-ve HTTP ofron kandidatë për fushat e emrit të hostit dhe portës pa llogari. Shtoni çelësat username dhe password nëse kërkohet llogaria e synuar e proxy-t.

AMQP mbi WebSockets përdor portën 443 të shërbimit, ndërsa transporti i zakonshëm AMQP përdor 5671. Proxy-t prapëseprapë duhet t'i lejojë lidhjen që krijohet drejt hapësirës së emrave Event Hubs.

Kredenciali i tokenit mund të bëjë kërkesa të veçanta HTTP gjatë marrjes së tokenëve. Konfiguroni transportin e mbështetur prej tij sipas nevojës kur edhe kjo rrugë vërtetimi ka nevojë për proxy-n.

Artikuj të ngjashëm