Azure Service Bus는 대규모 분산 시스템에서 메시지 교환을 위한 클라우드 네이티브 메시징 서비스입니다. 이 서비스를 사용하여 비동기 통신을 위해 메시지 큐, 토픽 및 구독을 만들고 관리할 수 있습니다. 파이썬을 사용하여 Azure Service Bus에서 메시지를 처리하는 방법을 알아보겠습니다.

1. Azure Service Bus에 연결하기

Azure Service Bus에 연결하려면 azure-servicebus 패키지를 설치해야 합니다. 다음 명령을 사용하여 패키지를 설치할 수 있습니다.

pip install azure-servicebus

Azure Service Bus에 연결하려면 해당 네임스페이스, 정책 이름 및 키를 알아야 합니다. 이를 사용하여 ServiceBusClient 객체를 만들 수 있습니다.

from azure.servicebus import ServiceBusClient

conn_str = "<연결 문자열>"
servicebus_client = ServiceBusClient.from_connection_string(conn_str)

2. 메시지 전송하기

Azure Service Bus에 메시지를 전송하려면 ServiceBusSender 객체를 사용해야 합니다. 다음 코드는 ServiceBusSender 객체를 만들고 메시지를 전송하는 예제입니다.

sender = servicebus_client.get_queue_sender("<큐 이름>")
with sender:
    message = Message("Hello, Azure Service Bus!")
    sender.send_messages(message)

3. 메시지 수신하기

메시지를 수신하려면 ServiceBusReceiver 객체를 사용해야 합니다. receive_messages() 메서드는 지정된 시간 동안 메시지를 받아옵니다.

receiver = servicebus_client.get_queue_receiver("<큐 이름>", receive_mode=ServiceBusReceiveMode.PEEK_LOCK)
with receiver:
    messages = receiver.receive_messages(max_message_count=10, max_wait_time=5)
    for message in messages:
        print(message)
        message.complete()

4. 메시지 처리 완료하기

메시지를 처리한 후에는 complete() 메서드를 호출하여 메시지 처리를 완료해야 합니다. 이렇게 하면 메시지가 대기열에서 제거됩니다.

마무리

파이썬을 사용하여 Azure Service Bus에서 메시지를 처리하는 방법을 살펴보았습니다. 이를 통해 메시지의 전송 및 수신과 같은 기본적인 작업을 수행할 수 있습니다. Azure Service Bus의 고급 기능과 관련된 자세한 내용은 Azure Service Bus 공식 문서를 참조하십시오.

#azure #AzureServiceBus