函数与触发器

类比于：无服务器函数运行时、Lambda、Cloud Functions

核心概念

请根据实际任务需要，选择性使用以下概念。并非每个 Worker 都需用到全部特性。

• 函数（Function） 是一个以唯一 ID 注册的异步处理器
• 触发器（Trigger） 将事件源绑定至函数 — 支持类型包括：http、durable:subscriber、cron、state、stream 和 subscribe
• 函数可通过 trigger() 调用其他函数，不受编程语言或 Worker 所在位置限制
• 引擎自动处理序列化、路由与投递
• 通过 HTTP 触发的函数可将外部端点封装为可调用的函数 ID
• 函数可声明其 请求/响应格式，用于文档生成与服务发现 — 格式自动从 Rust（通过 schemars::JsonSchema）、Python（通过类型提示 / Pydantic）中生成；Node.js 中则需手动提供

架构

registerWorker() 将 Worker 连接到引擎，registerFunction 定义处理器，registerTrigger 将事件源绑定至对应处理器，引擎负责将入站事件路由至正确的函数。函数可通过 trigger() 跨 Worker、跨语言调用其他函数。

iii 所用原语

参考实现

• TypeScript：../references/functions-and-triggers.js
• Python：../references/functions-and-triggers.py
• Rust：../references/functions-and-triggers.rs

各参考实现均以对应语言展示了相同模式：函数注册、触发器绑定、跨函数调用。

常见模式

采用该模式的代码通常包含（视具体场景而定）：

• registerWorker('ws://localhost:49134', { workerName: 'my-worker' }) — 连接引擎
• registerFunction('namespace::name', async (input) => { ... }) — 注册处理器
• registerTrigger({ type: 'http', function_id, config: { api_path, http_method, middleware_function_ids? } }) — HTTP 触发器（支持可选中间件）
• registerTrigger({ type: 'durable:subscriber', function_id, config: { topic } }) — 队列触发器
• registerTrigger({ type: 'cron', function_id, config: { expression } }) — Cron 触发器
• registerTrigger({ type: 'state', function_id, config: { scope, key } }) — 状态变更触发器
• registerTrigger({ type: 'stream', function_id, config: { stream } }) — 流触发器
• registerTrigger({ type: 'subscribe', function_id, config: { topic } }) — Pub/Sub 订阅者
• 跨语言调用：TypeScript 函数可通过函数 ID 触发 Python 或 Rust 函数
• registerTrigger({ ..., metadata: { owner: 'team', priority: 'high' } }) — 可选触发器元数据

请求/响应格式（自动注册）

函数可声明其输入/输出 Schema，用于文档生成与服务发现：

• Rust：为处理器的输入/输出类型派生 schemars::JsonSchema trait — RegisterFunction::new() 会基于该类型自动生成 JSON Schema（Draft 7）
• Python：在处理器参数与返回类型上使用类型提示（Pydantic 模型或基础类型）— register_function() 自动提取 JSON Schema（Draft 2020-12）
• Node.js：在注册消息中手动传入 request_format / response_format（例如通过 Zod 的 toJSONSchema() 方法）

该模式的适配方式

当以下适配项适用于当前任务时，请采用相应调整。

• 将占位符处理器逻辑替换为真实业务逻辑（如 API 调用、数据库查询、LLM 调用等）
• 使用 namespace::name 命名约定为函数 ID 分组，便于组织相关函数
• 针对 HTTP 端点，在触发器配置中设置 api_path 和 http_method
• 针对持久化异步任务，使用 TriggerAction.Enqueue({ queue }) 替代同步调用
• 针对即发即弃的副作用操作，使用 TriggerAction.Void()
• 不同语言的多个 Worker 可分别注册函数，并通过函数 ID 相互调用

模式边界

• 若关注 HTTP 端点细节（如请求/响应格式、路径参数），请优先选用 iii-http-endpoints。
• 若关注队列处理细节（如重试策略、并发控制、FIFO 保证），请优先选用 iii-queue-processing。
• 若关注 Cron 调度细节（如表达式语法、时区支持），请优先选用 iii-cron-scheduling。
• 若关注调用模式差异（同步 vs Void vs Enqueue），请优先选用 iii-trigger-actions。
• 当核心问题聚焦于函数注册、触发器绑定或跨语言调用时，请继续使用 iii-functions-and-triggers。

适用场景

• 当任务主要围绕 iii 引擎中的 iii-functions-and-triggers 展开时，应使用本技能。
• 当用户请求明确指向该模式，或要求实现等效功能时，应触发本技能。

边界约束

• 切勿将本技能作为无关任务的通用兜底方案。
• 当存在更贴切的专用 iii 技能时，不得使用本技能。
• 应用本技能中的示例前，必须验证运行环境与安全约束是否满足。