Azure Event Hubs Python-ში: AMQP WebSockets-ით HTTP პროქსის გავლით

გადასვით Event Hubs-ის http_proxy ლექსიკონი ჰოსტის სახელითა და მთელ რიცხვით პორტით და ამავდროულად აირჩიეთ WebSocket AMQP ტრანსპორტი.

HTTP პროქსის გამოყენებისას Event Hubs-ის Python მომხმარებლისთვის კლიენტის შექმნისას დააყენეთ 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-ის სახელი და credential აპლიკაციის არსებული სერვისის კონფიგურაციაა. განაგრძეთ მიღების callback-ებით და კლიენტის დახურვის ჩვეულებრივი სასიცოცხლო ციკლით.

ეს ლექსიკონი უშუალოდ აღწერს შუამავალს. ეს არ არის http/https დანიშნულების სქემების რუკა, რომელსაც Requests იღებს. საჯარო Event Hubs სივრცისთვის, სადაც საჯარო შუამავლები დაშვებულია, HTTP პროქსების სია გთავაზობთ კანდიდატებს ანგარიშის გარეშე ჰოსტის სახელისა და პორტის ველებისთვის. დაამატეთ username და password გასაღებები, თუ საჭიროა განზრახული პროქსის ანგარიში.

AMQP WebSockets-ით იყენებს სერვისის 443 პორტს, ხოლო ჩვეულებრივი AMQP ტრანსპორტი — 5671-ს. პროქსმა მაინც უნდა დაუშვას შედეგად წარმოქმნილი კავშირი Event Hubs-ის სივრცესთან.

token credential-ს შეუძლია ცალკეული HTTP მოთხოვნების გაგზავნა token-ების მიღების დროს. დააყენეთ მისი მხარდაჭერილი ტრანსპორტი საჭიროებისამებრ, როცა ამ ავთენტიფიკაციის გზასაც სჭირდება პროქსი.

დაკავშირებული სტატიები