Azure Event Hubs Python тілінде: HTTP прокси арқылы WebSockets үстіндегі AMQP

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 кілттерін қосыңыз.

WebSockets үстіндегі AMQP қызметтің 443 портын пайдаланады, ал қарапайым AMQP тасымалы 5671 портын пайдаланады. Прокси бәрібір Event Hubs namespace-іне пайда болатын қосылымға рұқсат беруі керек.

Token credential токендерді алу кезінде жеке HTTP сұрауларын жасай алады. Бұл аутентификация жолына да прокси қажет болғанда, оның қолдайтын тасымалын қажетінше конфигурациялаңыз.

Қатысты мақалалар