问题标签 [pull-queue]

Is there a way to lease tasks from a pull-queue when running the application locally using dev_appserver?

More Info:

I have a GAE app that uses pull queues. I need to lease tasks from that queue from a different service written in java. I am running the GAE app using dev_appserver on my machine. How do I lease tasks from this queue? The Docs on GAE state that I have to lease tasks by hitting a REST endpoint on https://www.googleapis.com/taskqueue/v1beta1/projects/taskqueues. This URI is not exposed by my machine.

我想在应用程序中使用GAE Task Queue( pull queue) 作为消息队列。receiveMessage其他消息队列服务（例如）中的AmazonSQS调用是异步调用，为应用程序提供 Web 可扩展性。

有pull queue调用：leaseTask而不是receiveMessage我想知道这个调用是否是异步的，因为我需要为我的应用程序提供 Web 可扩展性。

谢谢

我的项目基于 GAE/J 并利用最近推出的 PULL 队列，但我认为这个问题也可以应用于 Python。

基本上，当我将任务放入 PULL 队列时，我需要设置任务的一些参数，以供后面的消费者拾取。

我已经以两种方式在参数设置中实现了：

1）通过使用param()：

2）通过使用payload()：

两种方法都有效，但是，我想知道两者之间的区别是什么，就效率或便利性而言，哪种方式应该是首选方式。

我可以看到，通过使用param()，很容易设置多个参数，也很容易为消费者检索参数。但是对于一种参数情况，有效负载可能会更方便，因为它可以保存代码以捕获消费者提取参数时抛出的异常。

但是，除了我所说的之外，我很高兴知道这两者之间的更多区别。

我的应用程序使用 Java 运行，但我认为这也应该适用于 Python。

基本上我想要实现的是能够修改队列中的现有任务。

我们所有的任务都标有某些名称，以决定哪个提供者将使用它。但是，在某些情况下，一个标签的提供者出现故障，在这种情况下，我们希望其他提供者能够接手那些等待时间很长的任务。

为了做到这一点，我考虑的方法是，如果某些提供程序有一段时间没有从服务器轮询（预定义阈值），那么服务器将进入队列并将任务的标签修改为其他东西所以其他提供者可以使用它。

但我认为从文档中我找不到这样做的方法。

任何人都可以给出提示或者会有其他方法来解决这个问题吗？

我可以设置从任务队列中获取任务之前的最短时间吗？我想在 X 天后处理一项任务，例如有没有简单的方法或者我应该把这些信息放在任务本身？如果大部分任务只能在 3 天内执行，那么每 2 小时加载一次所有任务（例如，使用 cron 作业）听起来效率低下。

我正在尝试读取 Java 中的拉取队列（Google API）

这是代码：

还有我的进口：

我的代码中有 2 个错误：方法

使用方法覆盖

和

默认标题

不存在，我从这里的文档中获取了这段代码：https ://developers.google.com/appengine/docs/java/taskqueue/overview-pull

我尝试使用 Google 示例代码 - Taskqueue-cmdline-sample 对 Google Queue API 进行身份验证，

您必须在示例的 client_secrets.json 文件中设置 google 客户端 ID 和 google 客户端密码。

所以我的问题是在那里使用哪些凭据以及如何获取它们！另外，我们必须在 GAE 中 queue.xml 的 ACL 中使用电子邮件地址，而不是客户端 ID...

您在文档中有一个链接指向那里获取客户端 ID/秘密：http ://code.google.com/p/google-api-java-client/source/browse/shared/shared-sample-cmdline/ src/main/java/com/google/api/services/samples/shared/cmdline/oauth2/OAuth2Native.java?repo=samples

但它已经死了... (404) --> 已修复

文档：http ://samples.google-api-java-client.googlecode.com/hg/taskqueue-cmdline-sample/instructions.html

在那里查看示例：http ://code.google.com/p/google-api-java-client/source/checkout

更新

TaskQueue API 不在我的服务列表中。如何激活 TaskQueue API？

我正在尝试使示例正常工作，所以这里是代码：

示例代码

安装文档在那里：

安装文档

我在台阶上有一个小问题：

单击“API 访问”，然后单击“创建 OAuth 2.0 客户端 ID...”。输入产品名称，然后单击“下一步”。

控制台的 UI 可能已经升级，所以我使用这些数据在控制台中进行身份验证：

然后我运行程序，它把我带到网页以允许应用程序，然后我在控制台中收到以下错误消息：

我的 queue.xml ACL 设置了我用来进行身份验证的电子邮件

我很困惑我的队列是否真的是空的。从这个角度来看，名为“squid-pri-0”的队列表示队列中有 14 个任务：

但是当我点击它时，它说它是空的（见下文）。但是，我也看到了一个不是空白的“旧任务”，让我觉得它并不是真正的空白。我应该相信哪些数字/统计数据？

我正在尝试使用 python 使用计算 OAuth 令牌从谷歌计算访问拉取队列

我不断收到 HttpError 403“您不允许进行此 api 调用”

请帮忙，我错过了什么配置？

谢谢， 谢伊