Azure Event Hubs ב-Python: AMQP דרך WebSockets באמצעות פרוקסי HTTP

העבר את מילון ה-http_proxy של Event Hubs עם שם מארח ופורט שלם תוך בחירת תעבורת WebSocket AMQP.

עבור צרכן Event Hubs ב-Python שמשתמש בפרוקסי HTTP, הגדר בעת בניית הלקוח את מילון הפרוקסי של ה-SDK ואת תעבורת ה-WebSocket:

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 מספקת מועמדים לשדות שם המארח והפורט ללא חשבון. הוסף את המפתחות username ו-password אם נדרש חשבון הפרוקסי המיועד.

AMQP דרך WebSockets משתמש בפורט 443 של השירות, ואילו תעבורת AMQP הרגילה משתמשת ב-5671. הפרוקסי עדיין צריך להתיר את החיבור הנוצר אל מרחב השמות של Event Hubs.

אישור מבוסס אסימון יכול לבצע בקשות HTTP נפרדות בזמן השגת אסימונים. הגדר את התעבורה הנתמכת שלו לפי הצורך כאשר גם נתיב האימות הזה זקוק לפרוקסי.

מאמרים קשורים