
一个定时调度的程序,现在遇到的问题是, 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' |