Mosquitto Gateway Forwarding Topics to AWS IoT

Prerequsites

• Create a Python 3.4 (or above) virtual environment.
• Assume the Mosquitto Broker is configured, up and running.
• Assume Mosquitto and AWS IoT certificates and configuration is all setup.
  • Put the AWS IoT certificates in a folder named certs.awsiot/.
  • Put any required Mosquitto certificates in a folder named certs.mosquitto/.
• See Mosquitto README and AWS IoT README.

The Datashipper mosquitto_awsiot_datashipper.py and Publisher mosquitto_awsiot_publisher.py rely on the paho-mqtt and AWSIoTPythonSDK packages. Install them by running

pip install -r requirements.txt

Example Usage

• Datashipper that forwarding topic events/# to AWS IoT.
• An example publisher that publish to topic events/test by default.

python mosquitto_awsiot_datashipper.py &
python mosquitto_awsiot_publisher.py 

Proxy

MQTT is not compatible with http/https-proxy (?), but tsocks4/5 works fine.

If tsocks is set up on your machine you can run

tsocks python mosquitto_awsiot_datashipper.py

Can probably also be implemented using SocksiPy (?), something like this:

import socks
import socket
socks.setdefaultproxy(socks.PROXY_TYPE_SOCKS5, "127.0.0.1", 8080)
socket.socket = socks.socksocket