Cacher is the code snippet organizer for pro developers

import paho.mqtt.client as mqtt
import time


mqtt_username = 'ibJzvcJjWYf87eo'
mqtt_password = 'msLGo5E+dfSwS7U4FaM/uStvqiM='
mqtt_client_id = 'hBCFiCRlEUVS8bvd'
app_id = 'CMMCIO'

# The callback for when the client receives a CONNACK response from the server.
def on_connect(client, userdata, flags, rc):
    print("Connected with result code "+str(rc))

    # Subscribing in on_connect() means that if we lose the connection and
    # reconnect then subscriptions will be renewed.
    client.subscribe("/" + app_id + "/gearname/#")

# The callback for when a PUBLISH message is received from the server.
def on_message(client, userdata, msg):
    current_time = time.strftime("%Y-%m-%d %H:%M")
    print('['+current_time+']' + " IN >>> " + msg.topic+" "+str(msg.payload))

client = mqtt.Client(mqtt_client_id)
client.username_pw_set(mqtt_username, mqtt_password)
client.on_connect = on_connect
client.on_message = on_message

client.connect("gb.netpie.io", 1883, 60)

# Blocking call that processes network traffic, dispatches callbacks and
# handles reconnecting.
# Other loop*() functions are available that give a threaded interface and a
# manual interface.
client.loop_forever()