配置 Python 脚本队列

队列路由机制

当脚本的 defaultQueue 不为 0 时，系统会将任务路由到名为 {celery}{value} 的队列。例如：

• defaultQueue=1 → 任务进入 {celery}1 队列

• defaultQueue=2 → 任务进入 {celery}2 队列

对应的 Celery Pod 需要通过环境变量 CELERY_TASK_DEFAULT_QUEUE 指定自己监听的队列名，才能接收到这些任务。

默认队列 vs 独立队列

步骤一：部署独立 Celery Pod

要将脚本隔离到独立队列，需要部署独立的 Celery Pod，并配置对应的环境变量。

以将脚本路由到多队列（defaultQueue=1）为例：

# 默认队列 Pod（主 Pod）— 无需特殊配置
# CELERY_TASK_DEFAULT_QUEUE 未设置

# 独立队列 Pod — 监听 {celery}1 队列
CELERY_TASK_DEFAULT_QUEUE=1

如果需要使用高并发队列（defaultQueue=2），则配置：

# 独立队列 Pod — 监听 {celery}2 队列
CELERY_TASK_DEFAULT_QUEUE=2

部署完成后，不同 Pod 将各自监听不同的队列，实现脚本执行的物理隔离。

步骤二：通过 API 设置脚本的 defaultQueue

defaultQueue 字段当前未在前端界面暴露，无法通过页面直接修改。需要通过 API 调用的方式进行配置。

具体操作方式如下：

1. 在浏览器中打开先胜云平台的 元素管理 页面，找到目标 Python 脚本。

2. 打开浏览器开发者工具（F12），切换到 Network 标签页。

3. 在元素管理中对目标脚本执行一次 编辑并保存 操作（可以不做任何修改直接保存）。

4. 在 Network 中找到保存脚本的请求，右键点击该请求，选择 以cURL(bash)格式复制。

1. 将复制的 cURL 命令粘贴到 Postman 或其他 API 工具中。

2. 在请求体（Body）JSON 中找到 defaultQueue 字段，将其修改为所需的值：

   • "defaultQueue": 0 — 使用默认队列

   • "defaultQueue": 1 — 使用多队列

   • "defaultQueue": 2 — 使用高并发队列

3. 发送请求，完成队列配置。

{
  "elementName": "my_script",
  "content": "...",
  "defaultQueue": 1,
  "shouldLog": true
}

前端回显效果：

场景：CPU 密集型脚本隔离

假设有一个对外提供接口的 Python 脚本，具有以下特点：

• 并发和频率很高

• CPU 密集型计算

• 需要与其他脚本物理隔离以保证稳定性

配置步骤：

1. 运维团队部署第二个 Celery Pod，配置环境变量 CELERY_TASK_DEFAULT_QUEUE=1。

2. 通过 API 将目标脚本的 defaultQueue 设置为 1（参考上述步骤二）。

3. 保存后，该脚本的所有执行任务将被路由到独立 Pod，与默认队列的脚本物理隔离。