Azure Event Hubs Python-ում՝ AMQP WebSockets-ով HTTP պրոքսի միջոցով

Փոխանցեք Event Hubs-ի http_proxy բառարանը հոսթի անվան և ամբողջ թվային պորտի հետ՝ միաժամանակ ընտրելով WebSocket AMQP տրանսպորտը։

HTTP պրոքս օգտագործող Event Hubs-ի Python սպառողի համար հաճախորդը կառուցելիս կարգավորեք 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,
    },
)

Namespace-ը, Event Hub-ի անունը և credential-ը հավելվածի գոյություն ունեցող ծառայության կոնֆիգուրացիան են։ Շարունակեք դրա ընդունման callback-ներով և հաճախորդի փակման սովորական կենսացիկլով։

Այս բառարանը ուղղակիորեն նկարագրում է միջնորդին։ Սա Requests-ի ընդունած http/https նպատակակետ-սխեմաների քարտեզը չէ։ Հանրային Event Hubs namespace-ի համար, որտեղ հանրային միջնորդները թույլատրված են, HTTP պրոքսի ցանկը թեկնածուներ է տրամադրում առանց հաշվի հոսթի անվան և պորտի դաշտերի համար։ Ավելացրեք username և password բանալիները, եթե պահանջվում է նախատեսված պրոքսի հաշիվը։

AMQP-ն WebSockets-ով օգտագործում է ծառայության 443 պորտը, մինչդեռ սովորական AMQP տրանսպորտը՝ 5671-ը։ Պրոքսը դեռ պետք է թույլատրի ստացված կապը դեպի Event Hubs namespace։

Token credential-ը կարող է առանձին HTTP հարցումներ կատարել token-ներ ստանալիս։ Կարգավորեք նրա աջակցվող տրանսպորտը ըստ անհրաժեշտության, երբ այդ նույնականացման ուղին նույնպես պահանջում է պրոքսը։

Առնչվող հոդվածներ