Azure Event Hubs sa Python: AMQP sa WebSockets sa pamamagitan ng HTTP proxy

Ipasa ang http_proxy dictionary ng Event Hubs kasama ang hostname at integer na port habang pinipili ang WebSocket AMQP transport.

Para sa isang consumer ng Event Hubs sa Python na gumagamit ng HTTP proxy, i-configure ang proxy dictionary ng SDK at ang WebSocket transport kapag binubuo ang client:

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,
    },
)

Ang namespace, pangalan ng Event Hub at credential ay ang umiiral nang configuration ng serbisyo sa application. Magpatuloy sa mga receive callback nito at sa karaniwang lifecycle ng pagsasara ng client.

Direktang inilalarawan ng dictionary na ito ang tagapamagitan. Hindi ito ang mapa ng mga scheme ng destinasyon na http/https na tinatanggap ng Requests. Para sa pampublikong namespace ng Event Hubs kung saan pinapayagan ang mga pampublikong tagapamagitan, ang listahan ng HTTP proxy ay nagbibigay ng mga kandidato para sa hostname at port na walang account. Idagdag ang mga key na username at password kung kailangan ang inilaan na proxy account.

Gumagamit ang AMQP sa WebSockets ng port 443 ng serbisyo, samantalang ang karaniwang AMQP transport ay gumagamit ng 5671. Kailangan pa ring payagan ng proxy ang resultang koneksyon patungo sa namespace ng Event Hubs.

Ang token credential ay makakagawa ng hiwalay na HTTP request habang kumukuha ng token. I-configure ang sinusuportahang transport nito ayon sa pangangailangan kapag kailangan din ng proxy ang landas ng pagpapatunay na iyon.

Kaugnay na mga artikulo