Azure Event Hubs у Python-у: AMQP преко WebSockets кроз HTTP прокси

Проследите речник http_proxy за Event Hubs са именом домаћина и целобројним портом док бирате WebSocket AMQP транспорт.

За потрошача Event Hubs у Python-у који користи HTTP прокси, при изградњи клијента подесите речник проксија у SDK-у и WebSocket транспорт:

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

Простор имена, назив Event Hub-а и акредитив су постојећа конфигурација услуге у апликацији. Наставите са његовим повратним позивима пријема и уобичајеним животним циклусом затварања клијента.

Овај речник директно описује посредника. То није мапа одредишних шема http/https коју прихвата Requests. За јавни Event Hubs простор имена у којем су јавни посредници дозвољени, списак HTTP проксија нуди кандидате за поља имена домаћина и порта без налога. Додајте кључеве username и password ако је потребан предвиђени прокси налог.

AMQP преко WebSockets користи порт 443 те услуге, док обични AMQP транспорт користи 5671. Прокси ипак мора да дозволи насталу везу ка простору имена Event Hubs.

Акредитив токена може да шаље засебне HTTP захтеве док прибавља токене. Подесите његов подржани транспорт према потреби када и тај пут провере идентитета захтева прокси.

Повезани чланци