annatisch

Table of Contents

1. The perfstress framework
   • The PerfStressTest base
   • Default command options
2. Adding performance tests to an SDK
   • Writing a test
   • Adding legacy T1 tests
3. Running the tests
4. Readme

annatisch

This document describes core scenarios for the Python 7.0 (Track 2) Service Bus SDK. The APIView can be found here

(Credit goes to Connie for giving a great skeleton to hack this off of)

Overview

Initialization

• Building a sender for a queue
• Building a sender for a topic
• Building a receiver for a queue

annatisch

Current API for long running polling operations is as follows:

    def status(self):
        # type: () -> Any
        ...

    def result(self, timeout=None):
        # type: (Optional[int]) -> Model
        ...

annatisch

Track 1 SDK used a sample, rather than an API to support this scenario:

async def message_processing(queue_client):
    while True:
        try:
            async with queue_client.get_receiver(session=NEXT_AVAILABLE, idle_timeout=1) as session:
                await session.set_session_state("OPEN")
                async for message in session:
                    print("Message: {}".format(message))

annatisch

Customer code: Message send

from azure.servicebus import Queue, Topic

# Sending to a queue
with Queue.sender(namespace='foo', queue_name='bar', credential='sas') as sender:
  sender.send(Message('Hello World'))
  
# Sending with a connection string