SuperAPI AI 工具集

temporal-python

智能体与模型

查看项目

更新于 10-15 17:29

技能介绍

用途:使用 temporalio SDK 在 Python 中构建 Temporal 应用,编写具备持久性和容错性的分布式工作流。安装命令为 pip install temporalio,要求 Python >= 3.9。核心概念包括:Workflow(确定性编排类,禁止随机、真实 I/O 和系统时间)、Activity(执行副作用,可为同步或异步)、Worker(轮询任务队列并执行工作流与活动)、Client(启动、信号、查询、取消工作流)、Task Queue(路由工作的命名队列)。常用导入包括 from temporalio import workflow、from temporalio import activity、Client、Worker、RetryPolicy 及各类异常。建议使用单一 dataclass 参数传递数据以支持向后兼容。活动可用 @activity.defn 装饰,支持心跳、异步完成、类方法注入和动态活动。工作流通过 @workflow.defn 和 @workflow.run 定义,内部可使用 workflow.now()、workflow.random()、workflow.uuid4()、asyncio.sleep、asyncio.gather、asyncio.Lock 和 workflow.wait_condition;支持信号、查询、更新及验证器、持久定时器、并行活动、子工作流和 continue-as-new。工作流沙箱导入需使用 workflow.unsafe.imports_passed_through() 透传第三方模块。测试使用 temporalio.testing 的 WorkflowEnvironment 与 ActivityEnvironment。限制:工作流内不得执行 I/O、随机或系统时间调用;查询只读;验证器不得修改状态;同步活动需工作线程池。资料未提供收费、价格、平台或效果信息。