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 барања додека добива токени. Конфигурирајте го поддржаниот пренос по потреба кога и оваа патека за автентикација го бара проксито.

Поврзани статии