Azure Event Hubs dengan Python: AMQP melalui WebSockets lewat proksi HTTP

Teruskan kamus http_proxy milik Event Hubs beserta nama host dan porta bilangan bulat sambil memilih transport WebSocket AMQP.

Bagi konsumen Event Hubs di Python yang memakai proksi HTTP, konfigurasikan kamus proksi SDK dan transport WebSocket saat membangun 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,
    },
)

Namespace, nama Event Hub, dan kredensial adalah konfigurasi layanan yang sudah dimiliki aplikasi. Lanjutkan dengan callback penerimaannya dan siklus hidup penutupan klien yang biasa.

Kamus ini menjelaskan perantara secara langsung. Ini bukan peta skema tujuan http/https yang diterima Requests. Untuk namespace Event Hubs publik tempat perantara publik diizinkan, daftar proksi HTTP menyediakan kandidat untuk kolom nama host dan porta tanpa akun. Tambahkan kunci username dan password bila akun proksi yang dimaksud diperlukan.

AMQP melalui WebSockets memakai porta 443 layanan, sedangkan transport AMQP biasa memakai 5671. Proksi tetap harus mengizinkan koneksi yang dihasilkan ke namespace Event Hubs.

Kredensial token dapat membuat permintaan HTTP terpisah saat memperoleh token. Konfigurasikan transport yang didukungnya sesuai kebutuhan ketika jalur autentikasi itu juga memerlukan proksi.

Artikel terkait