我有两张table。每次程序运行时,buywalldata3都会被截断。
buywall是我想将插入buywalldata3的数据存储4小时的地方。
有时在运行代码时,同一个coinpair有多个条目。但是一旦这些条目被插入,我就不想在4小时内更新该coinpair的行。一旦这4个小时结束,我想再次更新这些条目。
这是因为我有另一个脚本,它在这4个小时内分析来自buywall的数据。
你知道怎么做吗?
这是一个加密警报机器人。
sql = "INSERT INTO BUYWALLDATA3 (COINPAIR, BUYWALLPRICE, BUYWALLSIZEINBTC, volumethreshold, datetimeofinsert) VALUES (%s, %s, %s, %s, NOW())"
val = [
(whichmarket[f], var_element_check[0], sum_array_check, volume_threshold)
]
mycursor.executemany(sql, val)
cnx.commit()
print(mycursor.rowcount, "was inserted.")
sql = "INSERT IGNORE INTO BUYWALL (COINPAIR, BUYWALLPRICE, BUYWALLSIZEINBTC, volumethreshold, datetimeofinsert) VALUES (%s, %s, %s, %s, NOW()) "
val = [
(whichmarket[f], var_element_check[0], sum_array_check, volume_threshold)
]
mycursor.executemany(sql, val)
cnx.commit()
这是两个表的布局(它们都是相同的)
1条答案
按热度按时间goqiplq21#
您希望定期将一个表的内容备份到另一个具有相同结构的表。最好总是保存到相同的、唯一的表中。
源表有一个时间戳字段,可用于筛选记录。您似乎在寻找一个where子句,它根据时间间隔过滤数据;那就是: