本页面演示了如何创建 App Engine 任务处理程序,即处理 App Engine 任务的工作器代码。Cloud Tasks 队列会将 HTTP 请求发送到您的任务处理程序。成功处理任务后,处理程序必须将 200
到 299
之间的 HTTP 状态代码发送回队列。任何其他代码都表示任务失败,队列将重试该任务。
App Engine 任务队列请求从 IP 地址 0.1.0.2
发送。另请参阅发送到 App Engine 环境的请求的 IP 范围。
C#
Python
Java
PHP
Go
Node.js
Ruby
超时
App Engine 任务有特定的超时限制,具体取决于运行它们的服务的伸缩类型。
对于在标准环境中运行的工作器:
- 自动扩缩:任务处理必须在 10 分钟内完成。
- 手动和基本扩缩:请求最长可运行 24 小时。
对于在柔性环境中运行的工作器服务:所有类型的工作器都有 60 分钟的超时时间。
如果处理程序错过截止时间,则队列会假定任务失败并重试。
读取 App Engine 任务请求标头
Cloud Tasks 队列发送到 App Engine 处理程序的请求具有特殊标头,其中包含处理程序可能想要使用的任务特定信息。
这些标头在内部设置。如果任何此类标头出现在您应用的外部用户请求中,它们会被内部标头替换,但来自已登录应用管理员的请求除外,他们可以出于测试目的设置标头。
App Engine 任务请求始终包含以下标头:
标头 | 说明 |
---|---|
X-AppEngine-QueueName |
队列名称。 |
X-AppEngine-TaskName |
任务的“短”名称,或者系统为任务生成的唯一 ID(如果在创建时未指定任务名称)。这是完整任务名称中的 my-task-id 值;例如 task_name = projects/my-project-id/locations/my-location/queues/my-queue-id/tasks/my-task-id 。 |
X-AppEngine-TaskRetryCount |
任务的重试次数。对于第一次尝试,该值为 0 。此数字包括由于缺少可用实例导致任务失败而从未到达执行阶段的尝试次数。 |
X-AppEngine-TaskExecutionCount |
任务执行和接收来自处理程序的响应的次数。由于 Cloud Tasks 会在收到成功响应后删除任务,因此之前的所有处理程序响应都是失败的。此数字不包括由于缺少可用实例而导致的失败次数。请注意,如果 X-AppEngine-TaskExecutionCount 在尝试执行之前进行更新,则可以等于 X-AppEngine-TaskRetryCount 。 |
X-AppEngine-TaskETA |
任务的计划运行时间,以 1970 年 1 月 1 日以来的秒数指定。 |
如果您的请求处理程序找到上述任何标头,就可以确信这是 Cloud Tasks 请求。
此外,来自 Cloud Tasks 的请求可能包含以下标头:
标头 | 说明 |
---|---|
X-AppEngine-TaskPreviousResponse |
来自上一次重试的 HTTP 响应代码。 |
X-AppEngine-TaskRetryReason |
重试任务的原因。 |
X-AppEngine-FailFast |
表示任务在现有实例不可用时快速失败。 |
目标路由
在 App Engine 任务中,队列和任务处理程序在同一个 Google Cloud 项目中运行。流量在传输过程中会加密,不会离开 Google 数据中心。您无法明确设置协议(例如 HTTP 或 HTTPS)。但是,对处理程序的请求表现为使用了 HTTP 协议。
任务可分派给安全的任务处理程序和不安全的任务处理程序,在受支持的运行时中,也可将任务分派给受 login: admin
限制的 URI。由于任务并非以任何用户身份运行,因此无法将任务分派给受 login: required
限制的 URI。任务调度也不遵循重定向。
后续步骤
- 如需详细了解任务,请参阅 RPC API 参考文档。
- 请参阅 REST API 参考,详细了解任务。