跳转到内容

set_queue_trigger_enabled — 启用或禁用队列消费

set_queue_trigger_enabled — 启用或禁用队列消费

Section titled “set_queue_trigger_enabled — 启用或禁用队列消费”

切换现有触发器,不修改队列或目标配置。

适用于稳定版 Viat 1.1.0。先阅读 MCP 配置与结果处理。以下为合成的、从源码推导的预期形状,不是已执行的响应。编写本页没有访问服务、提供方或设备。

需要编辑权限:项目 Owner、Admin 或 Developer;Viewer 被拒绝。PAT 所有者须具有该项目角色,且 PAT 范围允许访问该路由。

使用已激活的隔离实例,配置服务器和 bearer;除 list_projects 外须有 mcp-lab 项目。示例中的现有资产和 ID 以概览夹具为前提,用夹具实际返回 ID 替换合成 ID;示例不会自行创建依赖。

必填表示导出输入合约的结构要求,不等于完整条件 API 验证。可选字段的显式 JSON null 与省略同样反序列化,包括未限定类型的 JSON 字段。空字符串、数组或对象是实际值,不是省略。数值 format 表示序列化边界,运行时限制和默认值另算。args 的模式 default:null 不等于其运行时默认 {}。

字段类型必填省略 / 显式 null约束和含义
enabledboolean是无默认值,缺失或 null 无效。存储的启用标志,upsert 默认 true,切换工具必须提供布尔值。
namestring是无默认值,缺失或 null 无效。精确资产名;身份与文件夹规则见本页说明。
projectstring / null否(可能条件必填)VIAT_PROJECT / current_project;否则 project_required;null 等同省略。项目 slug;省略或 null 使用 VIAT_PROJECT/current_project,否则 project_required。

必填布尔值 enabled POST 到 enabled 动作。不能创建触发器或修改 ack_deadline_override。默认脚本超时上限可能超过 broker ack deadline,所以创建触发器需在控制台明确决定 deadline 策略,不要尝试用通用 JSON patch 绕过。

队列触发器对象包含字符串 name、resource、queue、target_kind(script 或 workflow)、target_name、updated_at,布尔值 enabled,整数 max_concurrent_runs,JSON 值 inputs,以及可选布尔值 ack_deadline_override(上游缺失时省略)。

无分页或续页游标。

值会序列化成 JSON,放进一个 MCP content 文本块。请把 result.content[0].text 解析为 JSON。不承诺 structuredContent 或 outputSchema;注明省略的可选字段不能假定以 null 存在。

完成 MCP initialize/initialized 后,通过 stdio 以单行 JSON 发送此 tools/call 请求(此处格式化仅为便于阅读)。

{
"jsonrpc": "2.0",
"id": 3,
"method": "tools/call",
"params": {
"name": "set_queue_trigger_enabled",
"arguments": {
"project": "mcp-lab",
"name": "mcp_queue",
"enabled": false
}
}
}

预期 MCP 外层形状(ID、时间戳、头和计算值均为示意,不是确定值断言)。

{
"jsonrpc": "2.0",
"id": 3,
"result": {
"content": [
{
"type": "text",
"text": "{\"name\":\"mcp_queue\",\"enabled\":false,\"resource\":\"queue_stub\",\"queue\":\"demo\",\"max_concurrent_runs\":1,\"ack_deadline_override\":true,\"target_kind\":\"script\",\"target_name\":\"mcp_demo\",\"inputs\":{},\"updated_at\":\"2026-01-01T00:00:00Z\"}"
}
],
"isError": false
}
}

文本块内解码后的 JSON 值:

{
"name": "mcp_queue",
"enabled": false,
"resource": "queue_stub",
"queue": "demo",
"max_concurrent_runs": 1,
"ack_deadline_override": true,
"target_kind": "script",
"target_name": "mcp_demo",
"inputs": {},
"updated_at": "2026-01-01T00:00:00Z"
}

未知触发器为上游 404,角色不足为 403。成功仅表示已保存启用状态,不保证 broker 消费者已经启动或排空。

所有上游工具都可能因令牌过期或撤销、PAT 范围、项目权限、激活、网络或超时失败。无项目及默认值时为 project_required;控制面非 2xx 为 http_4xx/http_5xx。详见 公共错误外层及重试规则。输入反序列化或未知工具可能在进入工具层前成为 JSON-RPC 协议错误,不要假定每个失败都有 isError。retryable 标志不保证幂等。

启用会开始真实消费和目标执行;禁用停止后续消费,不能撤销在途投递。示例禁用隔离夹具。记录原状态,仅在明确需要时恢复;MCP 没有队列触发器删除或消息重入队工具。

验证应以观察为主:检查本文结果字段,获准修改前后使用对应读取工具。不要通过生产请求或删除无关对象来验证。

输入清单:contracts/1.1.0/mcp-tools.json,工具 set_queue_trigger_enabled. 固定产品源码中的实现和测试: queue.rs; handlers/queue_triggers.rs; tests/it/tool_set_queue_trigger_enabled.rs. 工具模块文件名相对 crates/viat-mcp/src/tools/,API handler 相对 crates/viat-api/src/handlers/。公共传输和错误依据为 crates/viat-mcp/src/tools/service.rs、http.rs、error.rs;本次仅阅读测试,没有运行测试。