我有是导致DeadlineExceededError因为任务可以超过10分钟需要更长的时间任务队列中的长期运行的进程。 正如我在说明这个问题 ,长期运行过程中有一个for循环,依次是用来创建KML文件大型辞书计算新的值。 任务目前看起来是这样的:
class longprocess_handler(webapp2.RequestHandler):
def post(self):
#This is currently one task that recursively uses data in dictionaries to
#produce kml files every few minutes
for j in range(0, Time):
# Processes data from dictionaries sequentially in this for loop
# Sends message to client to request the data.
我想使这一过程分成几个小任务,比如:
class longprocess_handler(webapp2.RequestHandler):
def post(self):
for j in range(0, Time):
# Send dictionaries to smaller task
CallSmallerTask_handler(dictionaries)
# Receive dictionaries back from task. (How do I do this?)
# Repeat for loop with new dictionaries to call next task.
有没有办法从任务找回数据,这样我可以创建更小的任务,一个循环,使用的是以前的任务的结果依次制作? 我需要的字典从数据存储中的前一个任务存储并检索他们创造的下一个任务是什么? (我希望能避免这种情况,因为字典是非常大的,我想这可能是困难的)。