问题标签 [task-queue]

我不知道如何将单元测试指向队列配置文件。

单元测试片段

堆栈跟踪

java.lang.IllegalStateException：指定的队列未知：com.google.appengine.api.labs.taskqueue 的 com.google.appengine.api.labs.taskqueue.QueueApiHelper.translateError(QueueApiHelper.java:56) 的 zip-fetch .QueueApiHelper.translateError(QueueApiHelper.java:111) 在 com.google.appengine.api.labs.taskqueue.QueueApiHelper.makeSyncCall(QueueApiHelper.java:32) 在 com.google.appengine.api.labs.taskqueue.QueueImpl.add (QueueImpl.java:310) 在 com.google.appengine.api.labs.taskqueue.QueueImpl.add(QueueImpl.java:282) 在 com.google.appengine.api.labs.taskqueue.QueueImpl.add(QueueImpl.java :267) 在...

我正在使用 Goole App Engine 任务队列 API 来学习如何使用它。但我无法让它在本地触发。当我上传到 Google 服务器时，我的应用程序运行起来非常棒。但它不会在本地触发。我从管理员那里看到的只是任务列表。但是当他们的 ETA 到来时，他们只是通过了它。就像他们运行但他们失败并等待重试一样。但是我在命令行上看不到这些事件。

当我尝试在管理面板上单击“运行”时，它运行成功，我可以从命令行看到这些请求。我在带有 google-app-engine-django 的 Linux 上使用 App Engine SDK 1.3.4。我正在尝试从 3 小时内找到问题，但我找不到它。调试 GAE 应用程序也非常困难。因为调试消息不会出现在控制台屏幕上。

谢谢。

我创建了一个新的任务队列并在 queue.yaml 中定义了它

我不确定如何开始向此队列添加任务？

使用默认队列很简单 taskqueue.add(...)

我们如何为自定义队列做到这一点？

在来自“使用 Google App Engine 的数据管道”的视频/PDF 中，Brett 将“now / 30”放入任务名称中，并指出他稍后会解释原因，但不知何故他从来没有这样做过。:)
http://www.youtube.com/watch?v=zSDC_TU7rtc#t=41m35

你知道原因吗？这与不能重复使用任务名称的 7 天期限有关吗？

链接到会话页面

在我的本地开发环境中，当已添加到任务队列的 App Engine 任务遇到错误时，会重试直到成功。但是，在生产环境中，它不是。我认为正在发生的事情是，因为我在 urls.py 中有一个自定义的 500 处理程序，所以所有错误都会被它捕获，并且 500 错误永远不会冒泡到顶部。

这实际上可能是我的任务没有被重试的原因吗？如果是这样，有没有办法防止这种情况发生？如果请求是用户生成的，而不是后端任务，我只希望 handler500 视图捕获错误（对于那些，我希望错误冒泡并强制重试）。

我在 GAE 中使用任务队列进行某些数据更新。

我的 queue.xml 文件如下所示

我的队列处理 servlet 将每个任务的信用减 1。在处理时，它需要检查信用可用性，只有在信用可用时才继续进行。

积分存储在表格中，并在任务完成时更新。

我将任务视为线程并担心同步问题。

如果两个或多个任务同时查询/更新信用表怎么办？我需要创建一些锁定机制吗？如果是，那怎么办？

有没有办法在 google-app-engine 的队列中传递多个参数？我使用下面的代码

在我的 servlet 中，这个 id 作为查询字符串被检索。

我需要传递 6 个参数。

我需要间隔大约 2 分钟运行 2 个任务，但需要同时将它们插入队列中。我该怎么做呢？

有什么方法可以在这个执行中插入一个时间组件？

你能举个例子吗？

我在 Google App Engine 中每小时运行数千个任务，即使经过多次重试，其中大约 0.1% 的任务仍然失败。理想情况下，我希望他们停止尝试并退出。然而，由于应用引擎的设计，他们似乎只是一次又一次地尝试。我知道每次执行不成功都会增加一个退避时间，但我希望他们在完全重试 n 次后退出。

我能以某种方式做到这一点吗？一个任务可以计算它运行失败的次数吗？

我正在使用 Python GAE SDK。

我有一些处理需要在 6000 多个MyKind. 在单个请求中完成太慢了，所以我正在使用任务队列。如果我让一个任务只处理一个实体，那么它应该只需要几秒钟。

文档说只能在“批次”中添加 100 个任务。（这是什么意思？在一个请求中？在一项任务中？）

因此，假设“批处理”意味着“请求”，我试图找出为数据存储中的每个实体创建任务的最佳方法。你怎么看？

如果我可以假设的顺序MyKind永远不会改变，那就更容易了。（处理过程永远不会真正改变MyKind实例——它只会创建其他类型的新实例。）我可以做一堆任务，给每个任务一个从哪里开始的偏移量，间隔小于 100。然后，每个任务都可以创建执行实际处理的单独任务。

但是如果实体太多以至于原始请求无法添加所有必要的调度任务怎么办？这让我觉得我需要一个递归解决方案——每个任务都会查看它给定的范围。如果该范围内仅存在一个元素，则会对其进行处理。否则，它将范围进一步细分为后续任务。

如果我不能指望使用偏移量和限制来识别实体（因为不能确保它们的顺序是恒定的），也许我可以只使用它们的键？但随后我可能会发送 1000 多个密钥，这看起来很笨拙。

我在这里走的是正确的道路，还是我应该考虑另一种设计？