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 сурамдарын жасоого болот. Бул аутентификация жолуна да прокси керек болгондо, анын колдогон транспортун талапка жараша конфигурациялаңыз.

Тектеш макалалар