【发布时间】:2021-11-21 04:53:15
【问题描述】:
我通过 rabbitMQ 收到一条 json 消息,我想将它存储到数据库中。
消息如下所示:
message ={
"ticket": "ticket_12334345",
"items" : ["item1","item2","item3"],
"prices" : [10,20,15],
"full price" : [45]
}
存储到数据库如下所示:
def callback(ch, method, properties, body):
print("%r" % body)
body = json.loads(body)
conn = sqlite3.connect('pythonDB.db')
c = conn.cursor()
c.execute('CREATE TABLE IF NOT EXISTS Table_3 (ticket TEXT, items TEXT, prices INTEGER,'
'FullPrice INTEGER)')
c.execute("INSERT INTO Table_3 VALUES(?,?,?,?)", (body["ticket"],
body["items"], body["prices"], body["full price"],
))
conn.commit()
我收到一个错误 sqlite3.InterfaceError: Error binding parameter 0 - 可能是不受支持的类型。
我认为这是因为我没有正确存储列表数据。我想在列中将列表中的所有值放在一个单元格中。
【问题讨论】:
标签: python-3.x sqlite