SuperAPI AI 工具集

python-temporal

编程与开发

查看项目

更新于 10-16 00:06

技能介绍

用途:该技能提供在 Python 中使用 Temporal SDK 构建持久、分布式工作流的模式,适用于设计工作流、实现活动、处理重试、管理工作流状态等场景。

主要能力:涵盖 Worker 搭建、工作流定义、活动实现、启动工作流、错误处理以及信号与查询。示例中通过 Client.connect("localhost:7233") 连接服务,使用 Worker 绑定 task_queue、workflows 与 activities 并运行;用 @workflow.defn 与 @workflow.run 定义工作流,通过 workflow.execute_activity 调用活动并设置 start_to_close_timeout;用 @activity.defn 定义可失败并重试的活动;用 client.start_workflow 启动并获取结果;用 RetryPolicy(maximum_attempts=3) 配置重试,捕获 ActivityError 处理重试耗尽后的失败;用 @workflow.signal 与 @workflow.query 实现外部信号与状态查询,配合 workflow.wait_condition 等待条件。

使用方式:按资料中的代码模式组织 Worker、工作流与活动,连接本地 Temporal 服务地址 localhost:7233,指定任务队列与工作流 ID 后启动。

限制:资料仅给出上述模式与示例,未提供安装命令、依赖版本、部署方式、收费信息及完整测试细节;更多测试模式与常见工作流模式需参考其 references/ 目录。