Azure Event Hubs dalam Python: AMQP melalui WebSockets melalui proksi HTTP

Bagi pengguna Event Hubs dalam Python yang menggunakan proksi HTTP, konfigurasikan kamus proksi SDK dan pengangkutan WebSocket semasa membina klien:

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

Ruang nama, nama Event Hub dan kelayakan ialah konfigurasi perkhidmatan sedia ada aplikasi. Teruskan dengan callback penerimaannya dan kitaran hayat penutupan klien yang biasa.

Kamus ini menerangkan perantara secara langsung. Ia bukan peta skema destinasi http/https yang diterima Requests. Untuk ruang nama Event Hubs awam yang membenarkan perantara awam, senarai proksi HTTP menyediakan calon untuk medan nama hos dan port tanpa akaun. Tambah kunci username dan password jika akaun proksi yang dimaksudkan diperlukan.

AMQP melalui WebSockets menggunakan port 443 perkhidmatan, manakala pengangkutan AMQP biasa menggunakan 5671. Proksi masih perlu membenarkan sambungan yang terhasil ke ruang nama Event Hubs.

Kelayakan token boleh membuat permintaan HTTP berasingan semasa memperoleh token. Konfigurasikan pengangkutan yang disokongnya mengikut keperluan apabila laluan pengesahan itu juga memerlukan proksi.