问题标签 [task-queue]

我正在尝试迁移使用 servlet 完成的应用程序。我现在配置了 Spring。问题是排队的任务停止工作，他们没有等待使用countdownMillis方法在任务属性中设置的时间量。任务正在运行，无需等待。

任何想法？

谢谢。

我正在为 GAE 开发应用程序并尝试使用任务队列。目前，我只是通过 GAE 应用程序启动器在我的 Windows 机器上运行该东西，但是每当我尝试将任何东西排入队列时，开发“服务器”崩溃并且日志中充满了讨厌的输出。

我已经尝试在与其他工作的事务中运行它，所以我很确定工作已成功入队。

然而，不久之后开发服务器崩溃并且日志充满了这样的东西：

道歉 - 下面的回复发现了错字（真的，不是真的）。然而，当试图解决最初的问题时，这悄悄地出现了。如果我修正错字，排队的工作完成，但我的服务器仍然在日志中出现此错误：

如果我删除对 taskqueue.add 的调用，它可以正常工作（当然，没有排队的工作）。出了什么问题？

I'm trying to build and debug my first GAE application and have already benefited from the awesome support of Stackoverflowers to get where I am in having tasks being processed on the default queue. Thanks!

However, I wanted to use Queues to demonstrate how you would do some 'long' work in the background. My idea was:

1. Receive a request to process a large file.
2. Store the file and enqueue a task.
3. Return the response.
4. Process the file on the background.
5. Let the client know, via a Channel, that the work is done!

I have all this working but for one problem. On my development server the Task Queue doesn't seem to process tasks in the background. To simulate long running work I just popped a sleep in there.

It appears that the GAE development server is single threaded. It doesn't respond at all until the item has been processed off the queue? Is this assumption right? Any ideas?

Thanks

Adding code exanples:

我正在使用 Amazon SQS 实现一个任务队列（但我想这个问题适用于任何任务队列），根据工作已经重试多少次（将其移至不同的队列，增加可见性超时，发送警报..等）

跟踪失败的作业计数的最佳方法是什么？我想避免为工作保留一个集中的数据库：重试计数记录。我应该查看在队列中花费的时间而不是在监控过程中吗？IMO 充其量是丑陋或不干净的，迭代工作直到我找到古老的..

谢谢！安德拉斯

我试图在单个实体中保留大约 28,000 个“行”，例如 EMPLOYEE

基本上，我的目标是通过使用超过 30 秒的 PUT 来避免被终止/超时 - 如果我只是通过调用发送到 servlet 的 doPost() 请求来执行 28,000 个 PUT，则可能会发生这种情况。

所以我正在考虑使用 Google App Engine 文档中描述的任务。

本质上，我想在 war 目录中上传一个包含 28,000 名“员工”的 csv 文件。然后创建一个任务，将这 28,000 个员工行异步 PUT 到 EMPLOYEE 实体。

• Q1：这是一个可行的解决方案还是有更好的方法？同样，目标是执行 PUT 以避免由于 30 秒的限制而被终止。

• Q2：我应该使用什么 queue.xml 配置来确保我可以尽快执行这些 PUT？

• Q3：现在，我已经尝试过了，类似于博客条目： http: //gaejexperiments.wordpress.com/2009/11/24/episode-10-using-the-task-queue-service/但我得到了大约 23 秒后出现以下错误：

  /li>

• Q4：我还检查了http://localhost:8888/_ah/admin上的数据存储查看器，它似乎只在该实体中创建了 1000 个结果。1000是极限吗？

• Q5：如何摆脱上述错误？

• Q6: 可以确认一个任务的最大允许时间是 10 分钟吗？还是30秒？我确实遇到过这个：http ://code.google.com/appengine/docs/java/taskqueue/overview.html#Task_Execution

我想运行 50 个任务。所有这些任务都执行同一段代码。唯一不同的是数据。哪个会更快完成？

一种。在队列中排队 50 个任务

湾。在 10 个不同的队列中排队 5 个任务

在使用另一个队列之前，是否有任何理想数量的任务可以在 1 个队列中排队？

我正在尝试在谷歌应用程序引擎上实现上述目标，并且想知道是否有人知道这已经完成的项目？还是一个例子？

到目前为止，在我的实现中，我可以将单个对象写入内存。但是，我在使用 add_multi 输入多个对象时遇到问题。

谢谢你的帮助。

我想解决这样一个问题：我有一个 HTML 表单（如注册表单），提交会发送电子邮件。现在我将它作为页面请求的一部分发送。明显的缺点：

• 使请求更长
• 有时 smtp 服务器已关闭，或超时和电子邮件未发送

使用 PHP 时，我使用了基于队列的解决方案 - 我一直将对象/xml 放入队列主机，然后某种客户端检查了该队列。如果队列任务被成功处理，它会从队列中删除任务。我想知道，在 Windows / .NET 平台上是否有类似的实现？

谢谢，帕维尔

从 AppEngine TaskQueue 服务调用的 HTTP POST 正文的编码是什么？

如果我通过 创建任务TaskOptions#payload(byte[], String)，HTTP 请求正文的编码是什么？

同样，String创建的 viaTaskOptions#param(String, byte[])和检索的 via的编码是ServletRequest#getParameter(String)什么？

更新：我必须使用的字符集名称是什么

取回我通过提交的二进制数据TaskOptions#param(String, byte[])？

它似乎是一个 servlet-container 特定的默认值，在http://www.w3.org/TR/html4/interact/forms.html的“application/x-www-form-urlencoded”的定义中没有定义#h-17.13.4.1——因为所有这些都已经在 servlet API 中抽象出来了。

我在 GAE 中使用任务队列为我的应用程序执行一些后台工作。我知道某项特定任务有 10 分钟的时间限制。我关心的是如何在本地环境中测试这个东西。我尝试了线程睡眠，但它没有像谷歌应用引擎文档中提到的那样抛出任何异常。也就是这个时间限制是用CPU时间还是实际时间来衡量的。

谢谢。