一个定时调度的程序,现在遇到的问题是, next_exec_date 我在 navicat 中更新成老时间,程序并不能扫描到。 重启后就能扫描到。新手 python ,还不是很溜,求大家帮忙看看 main 方法里起了一个线程, run 方法如下 主要代码:
def run(self):
try:
conn = mysql.connector.connect(**config.dbconfig)
except mysql.connector.Error as e:
logging.error( str(e))
self.stop()
sql = 'select * '
sql += ' from task where next_exec_date < now() and state=1 limit 0,10'
cursor = conn.cursor()
while not self.thread_stop:
cursor.execute(sql)
result = cursor.fetchall()
logging.debug("扫描到%s 个任务...",len(result))
time.sleep(self.interval)
#end while
cursor.close()
conn.close()
1
lbp0200 2016-05-23 16:54:42 +08:00 via Android
黑产
|
2
yfl168648 OP 搞定了。。事务隔离级别的问题。
set global tx_isolation='read-committed' |