以设定的间隔Python轮询MSSQL

我需要轮询MSSQL数据库来观察正在运行的作业的状态。我想每隔X秒运行一次状态检查以查看status = done。我正在尝试使用线程模块。我用一些简单的打印语句测试了线程模块，它似乎可行，但是当我在我的pymssql脚本中尝试时，它不会。以设定的间隔Python轮询MSSQL

def watcher_query(cursor): 
    print 'Watching' 
    return cursor.execute(""" select * 
           from some_table' """) 
def is_it_done(row): 
    if row['status'] == 'done': 
     return row['the_id'], True 
    else: 
     return row['the_id'], False 

def d(cur): 
    watcher_query(cur) 
    for row in cur: 
     return is_it_done(row)[1] 
    threading.Timer(100, d).start() 

def job_watch(server): 
    with pymssql.connect(server_info) as conn: 
     with conn.cursor(as_dict=True) as cur: 
      is_done = false 
      while is_done: 
       is_done = d(cur)

不管我怎么设置threading.Timer给我看“看”语句打印不断。有没有更好的方法来设置轮询计时器？

我也尝试过使用Twisted来设置一个基本函数，它每X秒调用一个函数，直到满足某些条件。尽管如此，我还没有尝试使用MSSQL。

来源

2014-10-01 Ptrkcon

你的代码编写方式并不似乎是一个工作顺序：

它不会因为is_done = false编译，
如果固定为is_done = False，它跳过立即回路，
即使循环以某种合理的方式修复，您也永远不会调用threading.Timer(100, d).start()，并且在您从返回时不检查任何其他行10检查使用return is_it_done(row)[1]

不要紧实际定时辅助方法做什么，打印到控制台或检查数据库的第一行后直接回家，应该只是用相同的定时器相同。

什么是这样的：

import threading 


def is_it_done(): 
    # get some dummy predictable results 
    if not hasattr(is_it_done, 'results'): 
     is_it_done.results = iter([False] * 3) 
    return next(is_it_done.results, True) 


def job_watch(): 
    is_done = False 

    def d(): 
     is_done = is_it_done() 
     print('is_done: {}'.format(is_done)) 
     timer = threading.Timer(3, d).start() 

    d() 


job_watch()

来源

2014-10-01 05:17:46 famousgarkin

以设定的间隔Python轮询MSSQL

回答

相关问题