IoT Injector

Personal tool to simulate and publish common iot sensor readings to various cloud endpoints for testing

Current:

• AWS IoT Core
• Generic MQTT Broker, such as vm running mosquitto

Future:

• Azure EventHub/IoT Hub
• Generic CoAP/HTTP server
• Websockets

Certs

For proper functionality, create and populate a certs folder inside the directory of the relevant capability. For example:

MQTT with Mosquitto broker

iot-data-sim/
|-- lib/
|   |-- mqtt/
|   |   |-- __init__.py
|   |   |-- mqtt_connection.py
|   |   |-- certs/
|   |   |   |-- mosquitto.org.crt
|   |   |   |-- client.crt
|   |   |   |-- client.key
| ...
|-- main.py

AWS IoT Core as a Thing

iot-data-sim/
|-- lib/
|   |-- aws/
|   |   |-- __init__.py
|   |   |-- aws_connection.py
|   |   |-- certs/
|   |   |   |-- root-CA.crt
|   |   |   |-- your.cert.pem
|   |   |   |-- your.private.key
|   |   |   |-- your.public.key
| ...
|-- main.py

Config

# config.yaml

aws:
  iot_core:
    endpoint: "account-specific-prefix.iot.aws-region.amazonaws.com"
    port: 8883
    region: "your-aws-region"
    root_ca: "your-aws-root-ca" # this can be found at https://www.amazontrust.com/repository/AmazonRootCA1.pem
    cert: "your-cert.cert.pem"
    private_key: "your-private-key.private.key"
    client_id: "your-client-id" # note that client_id and topics might need to be explicitly added to your aws policy
    topic: "your-topic" 
    count: 10

azure:
  iot_hub:
    endpoint: "your-azure-iot-hub-endpoint"
    connection_string: "your-azure-connection-string"
    device_id: "your-azure-device-id"

mqtt:
  broker: "test.mosquitto.org"
  port: 8884
  auth:
    username: "rw"
    password: "readwrite"
  topic: "qsi_sensor"
  qos: 1
  retain: false
  interval: 5 # in seconds