Azure Event Hubs với Python: AMQP trên WebSockets qua proxy HTTP

Truyền từ điển http_proxy của Event Hubs kèm tên máy chủ và cổng số nguyên trong khi chọn phương thức vận chuyển WebSocket AMQP.

Với một trình tiêu thụ Event Hubs bằng Python có dùng proxy HTTP, hãy cấu hình từ điển proxy của SDK và phương thức vận chuyển WebSocket khi tạo máy khách:

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

Không gian tên, tên Event Hub và thông tin xác thực là cấu hình dịch vụ sẵn có của ứng dụng. Tiếp tục với các lệnh gọi lại nhận và vòng đời đóng máy khách thông thường.

Từ điển này mô tả trực tiếp bên trung gian. Đây không phải bản đồ lược đồ đích http/https mà Requests chấp nhận. Với không gian tên Event Hubs công khai nơi cho phép bên trung gian công khai, danh sách proxy HTTP cung cấp ứng viên cho các trường tên máy chủ và cổng không cần tài khoản. Thêm khóa username và password nếu cần tài khoản proxy dự định.

AMQP trên WebSockets dùng cổng 443 của dịch vụ, trong khi phương thức vận chuyển AMQP thông thường dùng cổng 5671. Proxy vẫn phải cho phép kết nối phát sinh tới không gian tên Event Hubs.

Thông tin xác thực dạng mã thông báo có thể thực hiện các yêu cầu HTTP riêng trong khi lấy mã thông báo. Hãy cấu hình phương thức vận chuyển mà nó hỗ trợ khi đường xác thực đó cũng cần proxy.

Bài viết liên quan