Azure Servicebus Py · Azure Diagnostics · microsoft/azure-skills · Skills Docs

Azure Servicebus Py · Azure Diagnostics · microsoft/azure-skills · Skills Docs

Exception	Cause	Fix
`ServiceBusAuthenticationError`	Invalid credentials	Check connection string, regenerate SAS key
`ServiceBusAuthorizationError`	Missing Send/Listen claim	Assign `Azure Service Bus Data Owner/Sender/Receiver` RBAC role
`ServiceBusConnectionError`	Network or firewall	Check AMQP port 5671, try `TransportType.AmqpOverWebsocket`
`OperationTimeoutError`	Service didn’t respond in time	Adjust retry config, verify network
`MessageLockLostError`	Processing exceeded lock duration	Use `AutoLockRenewer`, reduce processing time
`SessionLockLostError`	Session lock expired	Reconnect to session, keep renewing lock
`MessageSizeExceededError`	Message or batch too large	Reduce payload. Premium supports individual messages up to 100MB. Batch limit is computed from max message size on the client, so batches can also be impacted

import logging, sys

handler = logging.StreamHandler(stream=sys.stdout)
handler.setFormatter(logging.Formatter("%(asctime)s | %(threadName)s | %(levelname)s | %(name)s | %(message)s"))
logger = logging.getLogger('azure.servicebus')
logger.setLevel(logging.DEBUG)
logger.addHandler(handler)

# Enable AMQP frame tracing
from azure.servicebus import ServiceBusClient
client = ServiceBusClient(..., logging_enable=True)

from azure.servicebus import AutoLockRenewer

renewer = AutoLockRenewer()
with receiver:
    for message in receiver.receive_messages(max_message_count=10):
        renewer.register(receiver, message, max_lock_renewal_duration=300)
        # process message
        receiver.complete_message(message)