Google App Engine已添加任务缺失

当我将任务添加到任务队列时,有时会丢失任务。我没有得到任何错误,但我只是在我的日志中找不到任务。假设我添加了n个任务。如果没有完成这n个任务,计算就无法进行。但是,我发现这些n个任务中的一个或多个在添加之后就丢失了,我的整个算法在中间停止。 可能是什么原因 ? 我保留一个变量w来检查添加任务的次数。我观察到w = n虽然没有创建一些任务。
def addtask_whx(index,user,seqlen,vp_compress,iseq_compress):
global w
while True :
    timeout_ms = 100    
    taskq_name = 'whx'+'--'+str(index[0])+'-'+str(index[1])+'-'+str(index[2])+'-'+str(index[3])+'-'+str(index[5]) + '--' + user

    try :

        taskqueue.add(name=taskq_name+str(timeout_ms),queue_name='whx',url='/whx', params={'m': index[0],'n': index[1],'o': index[2],'p': index[3],'q':0,'r':index[5],'user': user,'seqlen':seqlen,'vp':vp_compress,'iseq':iseq_compress})
        w = w+1
        break
    except DeadlineExceededError:
        taskq_name = taskq_name + str(timeout_ms)
        time.sleep(float(timeout_ms)/1000)
        timeout_ms = timeout_ms*4
        logging.error("WHX Task Queue Add Timeout Retrying")
    except TransientError:
        taskq_name = taskq_name + str(timeout_ms)
        time.sleep(float(timeout_ms)/1000)
        timeout_ms = timeout_ms*4
        logging.error("WHX Task Queue Add Transient Error Retrying")
    except TombstonedTaskError:
        logging.error("WHX Task Queue Tombstoned Error")
        break   
    
已邀请:
免责声明:这不是您正在寻找的答案,但我希望它会帮助您。   计算不能继续   没有这些n任务完成 听起来你正在使用任务队列来完成它不想做的事情。您应该阅读:http://code.google.com/appengine/docs/java/taskqueue/overview.html#Queue_Concepts 任务不保证按照它们到达的顺序执行,并且不能保证它们只执行一次。在某些情况下,单个任务可能会被执行多次或根本不执行。此外,可以根据可用资源由App Engine自行决定取消和重新排队任务。例如,你的
timeout_ms = 100
非常低;如果必须启动新的JVM(可能需要几秒钟),则可以在任务n之前执行任务n + 1和n + 2。 简而言之,任务队列不是执行严格顺序计算的可靠机制。你被警告过了。 -tjw     

要回复问题请先登录注册