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 विनंत्या करू शकते. त्या प्रमाणीकरण मार्गालाही प्रॉक्सीची गरज असताना त्याची समर्थित वाहतूक आवश्यकतेनुसार कॉन्फिगर करा.