Azure Event Hubs Python ile: HTTP proxy üzerinden WebSockets üzerinde AMQP

Event Hubs http_proxy sözlüğünü ana bilgisayar adı ve tam sayı bağlantı noktasıyla geçirin ve aynı zamanda WebSocket AMQP taşımasını seçin.

HTTP proxy kullanan bir Event Hubs Python tüketicisi için istemciyi oluştururken SDK'nın proxy sözlüğünü ve WebSocket taşımasını yapılandırın:

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

Ad alanı, Event Hub adı ve kimlik bilgisi uygulamanın mevcut hizmet yapılandırmasıdır. Ardından alım geri çağrıları ve istemcinin olağan kapatma yaşam döngüsüyle devam edin.

Bu sözlük aracıyı doğrudan tanımlar. Requests'in kabul ettiği http/https hedef şema haritası değildir. Genel aracılara izin verilen genel bir Event Hubs ad alanı için HTTP proxy listesi, hesap gerektirmeyen ana bilgisayar adı ve bağlantı noktası alanları için adaylar sunar. Amaçlanan proxy hesabı gerekiyorsa username ve password anahtarlarını ekleyin.

WebSockets üzerinde AMQP hizmetin 443 numaralı bağlantı noktasını kullanırken olağan AMQP taşıması 5671 numaralı bağlantı noktasını kullanır. Proxy yine de Event Hubs ad alanına oluşan bağlantıya izin vermelidir.

Belirteç kimlik bilgisi, belirteçleri alırken ayrı HTTP istekleri yapabilir. Bu kimlik doğrulama yolu da proxy gerektirdiğinde desteklediği taşımayı gerektiği gibi yapılandırın.

İlgili makaleler