task-queue

0热度

1回答

将任务添加到任务队列时，我想确保只有一个这样的任务。如果这个任务已经存在，我想删除它并添加新的任务（推迟它的执行也是可以的）。这是我的代码： queue = taskqueue.Queue() queue.delete_tasks_by_name('task_name') task = taskqueue.Task( name = 'task_name', url = '/t

1热度

1回答

App Engine搜索：如何并行搜索多个搜索索引？

我有很多索引，而且目前速度很慢，因为当用户查询时，它依次遍历每个结果，然后附加结果。 indexes = search.get_indexes(index_name_prefix=userDomain, limit=200) domain_indexes = [index for index in indexes if userDomain==str(index.name).split(":")[

1热度

2回答

我如何配置芹菜任务

我正在项目中使用芹菜，在那里我用它作为调度程序（作为定期任务）。我芹菜任务是这样的： @periodic_task(run_every=timedelta(seconds=300)) def update_all_feed(): feed_1() feed_2() ........... feed_n() 但作为饲料的数量增加它花费很长的时间去其他饲

0热度

2回答

InvalidQueueModeException而在应用服务引擎

添加和租赁任务我有以下队列定义 <queue> <name>ranker-queue</name> <mode>pull</mode> </queue> 在10倍 Queue q = QueueFactory.getQueue("ranker-queue"); TaskOptions taskOptions = TaskOptions.Builder.withM

2热度

3回答

即使task_retry_limit = 0，appengine也会运行失败的任务两次

我在taskqueue API中看到了一个bug行为。当任务失败时，即使我不告诉它，appengine也会再次运行它。这是相关代码： NO_RETRY = TaskRetryOptions(task_retry_limit=0) class EnqueueTaskDapau(webapp2.RequestHandler): def get(self): taskque

1热度

1回答

远在未来的GAE任务队列ETA

从现在起甚至1年后的1个月内，对于GAE推送任务队列创建任务是否存在风险/注意事项？

1热度

1回答

拉入队列leaseTasks没有返回任何TaskHandles

我试图在谷歌AppEngine上使用Pull Queue，这里是设置用户将通过我的应用程序REST API创建任务然后，它增加了一个任务为“TEST_QUEUE”（模式：PULL） cron作业将检查QueueStatistics，看看是否有任何尚未完成的任务，并计算工人开始的数量和推动工人ç onfig（租赁，任务的数量来获取等）到Push Queue 在推队列处理程序，我做了一些合理性检查

2热度

1回答

GAE任务队列击中端点API

我有一个端点API名为 “的GameAPI” 我有一个名为API： @ApiMethod(name = "startNewRound", path = "evaluateRound", httpMethod = HttpMethod.POST) 我试图运行下面的任务队列： queue.add( ofy().getTransaction(), TaskOptions.Builder.withUrl(

0热度

2回答

我该如何检查我是否已经排队完成任务？

我想在App Engine任务队列上添加一个任务，但前提是它尚未排入队列。我如何检查它是否已经排队？从任务队列API中不明显，但也许我错过了它。他们关键的任务（参数？）将是user_id。用例：我每隔一分钟就会检查一次新邮件。这需要非常频繁地发生。但是，有时这个队列中还有其他工作（他们都需要成为同一队列的一部分，因为他们使用的是外部服务，Gmail API，它的速率限制为10 qps，我只能通过速

1热度

1回答

App Engine - 计划用户发起的重复操作？

我试图找出一种安排重复操作（用相当短的重复时间）与由某些用户操作引起的初始化的方法。任务和克朗似乎都不适合这一点。 Cron似乎不适合用户初始化的事情，并且任务似乎不适合重复计划。我想让用户做一些事情，然后开始重复操作。应该每5秒采取一次行动。最终当用户做其他事情时，重复动作结束。是否还有一些我不知道的App Engine的其他部分对于处理这个问题最好？还是有一个很好的方式去做这个任务或cro