Use to load test IoT applications running on the AWS IoT service
Switch branches/tags
Nothing to show
Clone or download
concurrencylabs Fixed callback names so they work with Paho v1.2
Callbacks were named _on_*, which collides with callbacks in Paho v1.2.
This made the callbacks on the locust mqtt implementation to stop
working and not record results to Locust. Updated the callback names to
_locust_* and fixed the issue.
Latest commit 1c32e79 Jul 19, 2016

For more details, read this article:

Load test for AWS IoT applications using and Paho MQTT client

This repo is based on code found originally here


IoT Locust Architecture

This setup creates virtual IoT devices using Locust, which publishes messages to the AWS IoT message broker. Once messages arrive to AWS IoT, you can configure rules that integrate with other AWS services, such as Dynamo DB, Kinesis, Lambda, S3, SNS, SQS or CloudWatch.


  • Highly recommended to use virtualenv when installing and running this test.
  • Python 2.7.9 or later. The code in this repo requires support for TLSv1.2, which is available starting in Python 2.7.9
  • The code in this repo does NOT work with Python 3 due to Locust not supporting Python 3.
  • GCC (GNU Compiler Collection), required by Locust: sudo yum install gcc
  • GCC C++, required by Locust: sudo yum install gcc-c++
  • Locust: pip install locustio
  • OpenSSL v1.0.1 or greater (also due to TLSv1.2)
  • Paho MQTT client: pip install paho-mqtt

This file contains logic to create an MQTT client, initiate a connection, publish messages to a topic and subscribe to a topic. It also reports failure or success results to Locust.

At the time, it only supports QoS=0, which is what is needed for connecting to the AWS IoT service.

Another important feature is the support for TLSv1.2, which is required by AWS IoT in order to establish a secure connection. You must create certificate files for AWS IoT, attach an IAM policy to them in AWS and your locust tests must indicate the location of the certificate files in your system.

This file creates a basic locust test that publishes messages to an AWS IoT topic. The payload is a random value between 0 and 10, which represents a temperature reading.


Follow the instructions in the AWS IoT documentation in order to create certificate files. Follow the instructions here to create a CA certificate. Set environment variables CA_CERT, IOT_CERT and IOT_PRIVATE_KEY with the full location of your .pem files


Set the environment variable MQTT_TOPIC with the topic you want to publish messages to.

Running the test

First you need to get the endpoint AWS IoT has assigned to your account, using the AWS CLI: aws iot describe-endpoint

then run the locust command from your environment:

locust --host=<my AWSIoT endpoint> -f