[(u'0000000028037c08', u'2017-02-08', u'11-29-52'), (u'0000000028037c08', u'2017-02-08', u'11-31-02'), (u'0000000028037c08', u'2017-02-08', u'11-32-01'), (u'0000000028037c08', u'2017-02-08', u'11-33-02'), (u'0000000028037c08', u'2017-02-08', u'11-34-01')]

import mysql.connector
conn = mysql.connector.connect(host = 'localhost', database = 'mydatabase', user = 'root', password = 'Abcdef')
cursor = conn.cursor()
cursor.execute('select * from DT')
data = cursor.fetchall()
decoded = [[word.encode("utf8") for word in sets] for sets in data]
(machineId, Date, Time) = zip(*decoded)
sql = """insert into DTA (machineID, Date, Time) values(%s,%s,%s)""" % (machineId, Date,Time)
cursor.execute(sql)
cursor.commit()

mysql.connector.errors.DataError: 1241 (21000): Operand should contain 1 column(s)

import paho.mqtt.client as mqtt

def on_connect(client, userdata, flags, rc):
    client.subscribe("helloworld")
def on_message(client, userdata,msg):
    result = str(msg.payload)
    decoded = [[word.encode("utf8") for word in sets] for sets in result]
    print decoded
client = mqtt.Client()
client.on_connect = on_connect
client.on_message = on_message
client.connect("test.mosquitto.org", 1883,60)
client.subscribe("hello world",0)
client.loop_forever()

def on_message(client, userdata,msg):
    result = str(msg.payload)
    decoded = [[word.encode("utf8") for word in sets] for sets in result]
    (machineId, Date, Time) = zip(*decoded)
    sql = """insert into DTA (machineID, Date, Time) values(%s,%s,%s)""" % (machineId, Date,Time)
    cursor.execute(sql)
    cursor.commit()