Azure Service Bus SDK — Python
Package: azure-servicebus | README | Full Troubleshooting Guide
Common Errors
| 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 |
Enable Logging
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)AutoLockRenewer
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)Key Issues
- Mixing sync/async: Don't use
time.sleep()in async code; useawait asyncio.sleep(). - Dead letter debugging: Use
sub_queue=ServiceBusSubQueue.DEAD_LETTERto inspectdead_letter_reasonanddead_letter_error_description. - Always close clients: Use
withstatement or callclose()to avoid connection leaks.