问题标签 [google-cloud-tasks]

尝试使用 google 提供的 python 示例代码将任务添加到 Google Cloud Tasks 队列。来自谷歌的文档在这里：https ://cloud.google.com/tasks/docs/creating-appengine-tasks

当我尝试执行端点时，出现以下错误：

ImportError：无法导入名称“resource_pb2”

有没有人见过类似的问题并知道如何解决这个问题？

在此先感谢您的时间 ：）

-内森

我尝试将 google-cloud-tasks、google-api、google-cloud 添加到我的 requirements.txt 并在我的虚拟环境中运行 pip install google-cloud-tasks。我也尝试使用此代码：

从 google.cloud 导入 tasks_v2beta3

结果是一样的

这是google提供的示例代码。我已向他们发送了一条说明，让他们知道示例代码不起作用。

我希望代码将任务添加到 Cloud Tasks Queue，但我得到了这个堆栈跟踪：

我正在使用这个包将 Google Cloud 任务添加到我的项目中，并且效果很好。问题是我不知道如何增加 http 目标请求超时？

我有一个谷歌云任务队列（速率：10/s，存储桶：200，并发：1）将任务分派给 App Engine 服务（python 2.7 运行时）中的工作人员任务通常添加到队列中大约 3-4/ s。每个任务一次处理一个（无并发）

一般来说，每个任务的处理速度都非常快（小于 1sg）。令人惊讶的是，队列有时会随机“暂停”一小部分 5-20 个任务。新的传入任务照常处理，但这些任务被阻塞并在队列中停留几分钟，即使工人空闲并可能处理它们。7-9 分钟后，它们会自动处理，无需任何其他交互。问题是这种延迟太多而且不可接受:(

在“暂停”时，我可以通过单击“运行”按钮手动执行这些任务，它们会立即得到处理。所以我会放弃对工人方面的某种限制。

我尝试重新部署 queue.yaml。我还尝试暂停和恢复队列。两者都没有效果。

不会通知任何错误。任务不会重试，只是忽略几分钟。

有没有人经历过这种行为？任何帮助将不胜感激。谢谢。

我已阅读 Cloud Tasks API 文档来管理大量分布式请求的执行。

但是我在文档中找不到任何可以重试任何特定任务的内容。

使用 Cloud Tasks API 创建任务的请求正文是：

此请求正文中没有可设置的重试参数。但是，使用 Cloud Tasks API 创建队列时可以使用retryConfig，但问题是它为整个队列设置重试，而不是为特定任务设置重试。

我需要类似于 taskqueue.add() 中可用的 TaskRetryOptions 的功能

这在 Cloud Tasks API 中可能吗？

我正在尝试使用 Google Cloud Tasks，通过“试用此 API”网络功能或 Ruby Google Cloud SDK 创建任务。

我无法将有效负载交付给工作人员。

1. 将 Http 方法作为 POST 发送实际上有效，但在 Cloud Tasks UI 中显示为 GET。

2. 没有负载或标头发送到工作人员或显示在 Cloud Task UI 中。我尝试过 Base64、JSON、普通字符串。（见下图）

例子：

要求：

回复：

示例 Ruby 代码：

谷歌云用户界面截图：

空标题

空有效载荷

是否有一些特殊的格式来设置通过 POST 传递的有效负载？

谢谢！

我正在通过 http 使用 PHP 设置 Google Cloud Tasks，但不明白我是否需要关闭连接？

我在找两个地方：

1)文档

2) Gcloud 客户端库

我的版本：

我正在使用 App Engine，如果它有什么不同的话。

我知道如何为队列设置重试次数（maxAttempts）。

但是有没有办法为该队列中的特定任务设置重试次数？

我发现了这个问题，但它看起来像是为一些 RPC 相关的东西设置了这些选项。

``

我正在尝试将 Google Cloud Tasks 的速率限制为每秒不超过 1 个已处理的任务。

我创建了我的队列：

描述它给了我：

在创建了一堆任务后，我可以在日志中看到其中许多任务在 1 秒的时间段内被不希望地处理：

如何正确强制它在这 1 秒的时间间隔内运行不超过 1 个任务？

更新 30/06：

我用基本设置再次尝试过，同样的问题。

有关设置和过程的更多详细信息：

1. 源代码https://github.com/GoogleCloudPlatform/python-docs-samples/tree/master/appengine/flexible/tasks，无修改
2. 部署 app.yaml，而不是 app.flexible.yaml
3. 多次触发任务：python create_app_engine_queue_task.py --project=$PROJECT_ID --queue=$QUEUE_ID --location=$LOCATION_ID --payload=hello
4. 检查日志：gcloud app logs read

这次他们花了一段时间才开始处理，但在那之后似乎他们都或多或少地同时处理了：

完整日志：

What I am doing? I am working on google cloud task queue handler. Queues pushed successfully. Google cloud executed these queue internally. I have created app.yaml file where I have written below lines:-

Now I opened command line and run this command "gcloud app deploy". Then my project is deployed on google cloud server. Now I try to make a DB connection but continuously showing error db connection timeout.

I want to access Google cloud Sql Instance in click_queue_result.php

Please give me suggestion how I can resolve it??

When I hit this url https://google-cloud-project-id.appspot.com/click_queue then following error is occurred:-

I use Google Cloud Tasks with AppEngine to process tasks, but the tasks wait about 2-3 minutes in the queue before being sent to my App Engine endpoint.

There is no "delay" set on the tasks, and I expect them to be sent right away.

So the question is: Is Cloud Tasks slow?

As you can see is the following screenshot, Cloud Tasks gives an ETA of about 3 mins: