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 κατά τη λήψη διακριτικών. Ρυθμίστε κατά περίπτωση τη μεταφορά που υποστηρίζουν, όταν και αυτή η διαδρομή ελέγχου ταυτότητας χρειάζεται τον μεσολαβητή.

Σχετικά άρθρα