Azure Event Hubs بلغة Python: بروتوكول AMQP عبر WebSockets من خلال وكيل HTTP

مرّر قاموس http_proxy الخاص بـ Event Hubs مع اسم المضيف والمنفذ الصحيح، واختر نقل WebSocket AMQP في الوقت نفسه.

بالنسبة لمستهلك Event Hubs المكتوب بلغة Python والذي يستخدم وكيل HTTP، اضبط قاموس الوكيل ونقل WebSocket في SDK عند إنشاء العميل:

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

إن مساحة الأسماء واسم Event Hub وبيانات الاعتماد هي إعدادات الخدمة القائمة في التطبيق. تابع بعد ذلك باستدعاءات الاستقبال ودورة الحياة المعتادة لإغلاق العميل.

يصف هذا القاموس الوسيط وصفًا مباشرًا. وهو ليس خريطة مخطط الوجهة http/https التي يقبلها Requests. أما في مساحة أسماء Event Hubs العامة حيث يُسمح بالوسطاء العامين، فإن قائمة وكلاء HTTP توفر مرشحين لحقلي اسم المضيف والمنفذ دون حساب. أضف مفتاحي اسم المستخدم وكلمة المرور إذا كان حساب الوكيل المقصود مطلوبًا.

يستخدم AMQP عبر WebSockets المنفذ 443 الخاص بالخدمة، بينما يستخدم نقل AMQP العادي المنفذ 5671. ولا يزال الوكيل بحاجة إلى السماح بالاتصال الناتج نحو مساحة أسماء Event Hubs.

يمكن لبيانات اعتماد رمزية أن تجري طلبات HTTP منفصلة أثناء الحصول على الرموز. اضبط النقل المدعوم لديها عند الحاجة عندما يحتاج مسار المصادقة هذا أيضًا إلى الوكيل.

مقالات ذات صلة