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 и идентификационните данни са съществуващата конфигурация на услугата в приложението. Продължете с неговите callback функции за получаване и обичайния жизнен цикъл на затваряне на клиента.

Този речник описва посредника пряко. Той не е картата на схемите за дестинация http/https, която приема Requests. За публично пространство от имена на Event Hubs, където публичните посредници са разрешени, списъкът с HTTP проксита предоставя кандидати за полетата за име на хост и порт без акаунт. Добавете ключовете username и password, ако е необходим предвиденият акаунт за прокси.

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

Идентификационните данни за токен могат да правят отделни HTTP заявки, докато получават токени. Конфигурирайте поддържания от тях транспорт според нуждата, когато този път за удостоверяване също изисква проксито.

Подобни статии