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 അഭ്യർത്ഥനകൾ നടത്താം. ആ പ്രാമാണീകരണ പാതയ്ക്കും പ്രോക്സി ആവശ്യമെങ്കിൽ അത് പിന്തുണയ്ക്കുന്ന ഗതാഗതം ആവശ്യാനുസരണം കോൺഫിഗർ ചെയ്യുക.