Azure Event Hubs ar Python: AMQP pār WebSockets caur HTTP starpniekserveri

Nododiet Event Hubs http_proxy vārdnīcu ar resursdatora nosaukumu un veselu skaitli portu, vienlaikus izvēloties WebSocket AMQP pārraidi.

Event Hubs patērētājam Python valodā, kas izmanto HTTP starpniekserveri, veidojot klientu, konfigurējiet SDK starpniekservera vārdnīcu un WebSocket pārraidi:

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

Nosaukumvieta, Event Hub nosaukums un akreditācijas dati ir lietojumprogrammas esošā pakalpojuma konfigurācija. Turpiniet ar tā saņemšanas atzvanīšanu un parasto klienta aizvēršanas dzīves ciklu.

Šī vārdnīca tieši apraksta starpnieku. Tā nav http/https galamērķa shēmu karte, ko pieņem Requests. Publiskai Event Hubs nosaukumvietai, kur atļauti publiski starpnieki, HTTP starpniekserveru saraksts piedāvā kandidātus resursdatora nosaukuma un porta laukiem bez konta. Pievienojiet atslēgas username un password, ja nepieciešams paredzētais starpniekservera konts.

AMQP pār WebSockets izmanto pakalpojuma portu 443, savukārt parastā AMQP pārraide izmanto 5671. Starpniekserverim joprojām jāatļauj izveidotais savienojums ar Event Hubs nosaukumvietu.

Tokena akreditācijas dati var veikt atsevišķus HTTP pieprasījumus, iegūstot tokenus. Ja arī šim autentifikācijas ceļam nepieciešams starpniekserveris, konfigurējiet tā atbalstīto pārraidi pēc vajadzības.

Saistītie raksti