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 token ئالغاندا ئايرىم HTTP تەلەپلىرىنى قىلالايدۇ. بۇ دەلىللەش يولىغا ۋاكالەتچىمۇ كېرەك بولغاندا، ئۇ قوللايدىغان توشۇشنى زۆرۈر بولغىنىچە تەڭشەڭ.

مۇناسىۋەتلىك ماقالىلەر