Google 会使用 AI 技术将内容翻译成您偏好的语言。AI 翻译可能包含错误。

配置队列路由、限制和重试

Cloud Tasks 可让您通过定义队列级路由、调度速率限制和重试行为来管理任务执行。您可以在创建队列或更新现有队列时配置这些设置。 gcloud tasks queues create 或 gcloud tasks queues update 使用的配置标志是相同的。

在队列级配置身份验证会覆盖任务级身份验证。如需了解详情，请参阅将 HTTP 目标任务与身份验证令牌搭配使用。

配置队列级路由

在队列级配置路由会覆盖在任务级设置的路由。如果您想将 Cloud Tasks 用作目标服务前面的缓冲区，或者需要更改队列中所有任务的路由，则此功能非常有用。

队列级路由适用于：

队列中的任务
在设置队列级路由后添加到队列的任务

限制

队列级路由与 Cloud Key Management Service (Cloud KMS) 客户管理的加密密钥 (CMEK) 不兼容。如果启用了 CMEK，您将无法执行以下操作：

在具有队列级路由的队列中创建任务
应用队列级路由

为 HTTP 任务配置队列级路由

您可以在创建队列或更新队列时配置队列以覆盖任务级路由。如需配置队列级路由，请将队列的 uriOverride 参数设置为您首选的路由。

如果您要将队列级路由作为对现有队列的更新应用，请先暂停队列，然后再应用更改；应用更改后，请等待一分钟再恢复队列。

暂停队列通过运行以下命令：
```
  gcloud tasks queues pause QUEUE_ID
  
```
将 QUEUE_ID 替换为队列的 ID。
更新或移除队列级路由。
- 如需更新队列级路由，请将 uriOverride 参数设置为更新后的路由。
- 如需使用 REST 或 RPC API 移除队列级路由，请执行以下操作：
  - REST API：为队列发送 patch 请求，其中包含空载荷，并将 updateMask 参数设置为 httpTarget。
  - RPC API：为队列发送 updateQueueRequest ，其中包含空载荷，并将 update_mask 参数设置为 http_target。
以下示例使用 REST API 更新任务路由到的主机：
```
curl -X PATCH -d @- -i \
  -H "Authorization: Bearer ACCESS_TOKEN" \
  -H "Content-Type: application/json" \
  "https://cloudtasks.googleapis.com/v2/projects/PROJECT_ID/locations/LOCATION/queues/QUEUE_ID?updateMask=httpTarget.uriOverride" << EOF
{
  "httpTarget": {"uriOverride":{"host":"NEW_HOST"}}
}
EOF
```
替换以下内容：
- ACCESS_TOKEN：您的访问令牌。您可以通过在终端中运行以下命令来获取此令牌：
```
gcloud auth application-default login
gcloud auth application-default print-access-token
```
- PROJECT_ID：您的 Google Cloud 项目的 ID。您可以通过在终端中运行以下命令来获取此 ID：
```
gcloud config get-value project
```
- LOCATION：队列的位置。
- NEW_HOST：您希望队列路由到的新主机。
等待一分钟。

新配置最多可能需要一分钟才能生效。等待恢复队列有助于防止任务使用旧配置进行调度。
运行以下命令以恢复队列：
```
gcloud tasks queues resume QUEUE_ID
```

为 App Engine 任务配置队列级路由

如需为 App Engine 任务配置队列级路由，请将队列的 appEngineRoutingOverride 参数设置为您首选的 App Engine 服务和版本。

设置队列级路由并覆盖任何任务级路由：
```
gcloud tasks queues update QUEUE_ID \
    --routing-override=service:SERVICE,version:VERSION
```
替换以下内容：
- QUEUE_ID：队列 ID（其简称）。
- SERVICE：负责任务处理的 App Engine 工作器服务。
- VERSION：应用版本。
例如，如果您设置了工作器服务来处理队列中的所有任务，则可以路由到该服务和默认版本：
```
gcloud tasks queues update QUEUE_ID \
    --routing-override=service:SERVICE
```

运行以下命令，验证队列是否已成功配置：

gcloud tasks queues describe QUEUE_ID --location=LOCATION

将 LOCATION 替换为队列的位置。

输出应类似如下所示：

appEngineRoutingOverride:
  host: SERVICE.PROJECT_ID.appspot.com
  service: SERVICE
name: projects/PROJECT_ID/locations/LOCATION_ID/queues/QUEUE_ID
rateLimits:
  maxBurstSize: 100
  maxConcurrentDispatches: 1000
  maxDispatchesPerSecond: 500.0
retryConfig:
  maxAttempts: 100
  maxBackoff: 3600s
  maxDoublings: 16
  minBackoff: 0.100s
state: RUNNING

如需移除队列级路由，请运行以下命令：
```
gcloud tasks queues update QUEUE_ID \
    --clear-routing-override
```
移除队列级路由后，任务级路由将应用于队列中的任务以及将来添加到队列的任务。

定义速率限制

速率限制决定了队列可以调度的最大速率，无论调度是首次尝试任务还是重试。

运行以下命令，设置队列可调度的并发任务的最大速率和数量：
```
gcloud tasks queues update QUEUE_ID \
    --max-dispatches-per-second=DISPATCH_RATE \
    --max-concurrent-dispatches=MAX_CONCURRENT_DISPATCHES
```
替换以下内容：
- QUEUE_ID：队列 ID（其简称）。
- DISPATCH_RATE：调度速率。这是存储桶中令牌的刷新速率。在任务流相对稳定的情况下，这相当于任务被调度的速率。
- MAX_CONCURRENT_DISPATCHES：队列中可以同时运行的最大任务数。
例如，如果您在未设置任何参数的情况下创建了队列，则可以通过运行以下命令来更新最大并发任务数量：
```
gcloud tasks queues update QUEUE_ID \
    --max-concurrent-dispatches=MAX_CONCURRENT_DISPATCHES
```

运行以下命令，验证队列是否已成功配置：

gcloud tasks queues describe QUEUE_ID --location=LOCATION

将 LOCATION 替换为队列的位置。

输出应类似如下所示：

name: projects/PROJECT_ID/locations/LOCATION_ID/queues/QUEUE_ID
rateLimits:
  maxBurstSize: 100
  maxConcurrentDispatches: MAX_CONCURRENT_DISPATCHES
  maxDispatchesPerSecond: 500.0
retryConfig:
  maxAttempts: 100
  maxBackoff: 3600s
  maxDoublings: 16
  minBackoff: 0.100s
state: RUNNING

定义队列处理速率的方法

您可以使用 Cloud Tasks API 或上传 queue.yaml 文件来定义队列处理速率。这两种方法都会生成使用相同底层机制的队列。

在这两种情况下，队列都使用令牌桶算法来控制任务执行速率。每个命名队列都有一个存储其令牌的存储桶。

应用每执行一个任务，系统就会从桶中移除一个令牌。队列会继续处理任务，直到其存储桶中的令牌用完为止。系统会按照您为队列指定的 max_dispatches_per_second 速率不断向令牌桶中补充填充新令牌。如果您的队列包含要处理的任务，并且队列的存储桶包含令牌，则系统会同时处理与令牌数量相同的任务，最多达到您设置的 max_concurrent_dispatches 值。

负载不均匀可能会导致存储桶中的令牌数量大幅增加，这可能会导致在收到大量请求时出现处理量暴增的情况。在这种情况下，您的队列可能会遇到超过 max_dispatches_per_second 速率的实际调度速率，这不仅消耗系统资源还会与用户服务请求争用资源。如果您使用队列管理基于相对较慢的下游服务 SLA 的调度速率，则会导致 HTTP 429（请求过多）或 HTTP 503（服务不可用）等错误。

当您使用任意 Cloud Tasks API 方法时，您有两个字段来定义队列调度速率：
- max_dispatches_per_second
- max_concurrent_dispatches
第三个字段 max_burst_size 由系统根据您为 max_dispatches_per_second 设置的值计算得出。如需了解详情，请参阅 RateLimits 消息。
当您使用 queue.yaml 方法时，可以设置所有三个元素：
- max_concurrent_requests，等于 max_concurrent_dispatches
- rate，等于 max_dispatches_per_second
- bucket_size，等于 max_burst_size

在大多数情况下，使用 Cloud Tasks API 方法并让系统设置 max_burst_size 可以非常高效地管理请求爆发期。但在某些情况下，具体来说是当所需速率较慢时，可以使用 queue.yaml 方法将 bucket_size 手动设置为较小的值，或者通过 Cloud Tasks 将 max_concurrent_dispatches 设置为较小的值 API 来为您提供更多控制权。

设置重试参数

如果任务未成功完成，Cloud Tasks 将根据您设置的参数，使用指数退避算法重试该任务。任务成功执行后，系统会将其从队列中移除。在所有情况下，系统还会应用最大任务保留期限限制。

（可选）您可以指定任务级重试配置，该配置会覆盖任务的队列级重试配置。如需了解详情，请参阅为任务设置重试参数。

运行以下命令，指定队列中失败任务的最大重试次数，设置重试尝试的时间限制，并控制尝试之间的间隔：
```
gcloud tasks queues update QUEUE_ID \
    --max-attempts=MAX_ATTEMPTS \
    --max-retry-duration=MAX_RETRY_DURATION \
    --min-backoff=MIN_INTERVAL \
    --max-backoff=MAX_INTERVAL \
    --max-doublings=MAX_DOUBLINGS
```
替换以下内容：
- QUEUE_ID：队列 ID（其简称）。
- MAX_ATTEMPTS：任务的最大尝试次数，包括首次尝试。如需允许无限次重试，请将此值设置为 -1。即使达到 MAX_ATTEMPTS 或将其设置为 -1，MAX_RETRY_DURATION 仍然适用。
- MAX_RETRY_DURATION：重试失败任务的最长时间（从首次尝试任务时算起）。该值必须是以“s”结尾的字符串，例如 5s。如需指定无限时长，请将此值设置为 0s。即使达到 MAX_RETRY_DURATION 或将其设置为 0s，MAX_ATTEMPTS 仍然适用。
注意：如果您指定无限次尝试（MAX_ATTEMPTS 为 -1）和无限时长（MAX_RETRY_DURATION 为 0s），则系统会重试任务，直到达到最大任务保留期限限制。否则，Cloud Tasks 仅在满足这两个条件或任务成功后才会停止重试。当任务尝试了 MAX_ATTEMPTS 次且 MAX_RETRY_DURATION 时间已过时，系统将不再进行尝试，并删除该任务。
- MIN_INTERVAL：重试尝试之间等待的最短时间。该值必须是以“s”结尾的字符串，例如 5s。
- MAX_INTERVAL：重试尝试之间等待的最长时间。该值必须是以“s”结尾的字符串，例如 5s。
- MAX_DOUBLINGS：在间隔增加变为恒定之前，失败任务重试之间的间隔将加倍的最大次数。任务的重试间隔从 MIN_INTERVAL 开始，然后加倍 MAX_DOUBLINGS 次，然后线性增加，最后以 MAX_INTERVAL 的间隔重试，最多 MAX_ATTEMPTS 次。
  
  例如，如果 MIN_INTERVAL 为 10s， MAX_INTERVAL 为 300s，且 MAX_DOUBLINGS 为 3，则重试间隔将加倍 3 次，线性增加 2^3 * 10 秒，然后以 MAX_INTERVAL 的间隔重试，直到任务尝试了 MAX_ATTEMPTS 次：10 秒、20 秒、40 秒、80 秒、 160 秒、240 秒、300 秒、300 秒，依此类推。

如需了解更多参数详细信息，请参阅 RetryConfig resource 的 Queue 设置。

运行以下命令，验证队列是否已成功配置：
```
gcloud tasks queues describe QUEUE_ID --location=LOCATION
```
将 LOCATION 替换为队列的位置。

输出应包含您设置的重试参数。

后续步骤

了解如何创建 HTTP 目标任务。
了解如何创建 App Engine 任务。
如需详细了解队列管理，请参阅 RPC API 参考文档。
如需详细了解队列管理，请参阅 REST API 参考文档。