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 అభ్యర్థనలు చేయగలదు. ఆ ప్రామాణీకరణ మార్గానికి కూడా ప్రాక్సీ అవసరమైనప్పుడు అది మద్దతిచ్చే రవాణాను అవసరాన్ని బట్టి కాన్ఫిగర్ చేయండి.

సంబంధిత వ్యాసాలు