讲师中心 微信公众号

工具推荐

视频效率加速
立刻MV
立刻MV

低成本歌曲 MV、视频生成

updream

一键生成高质量推广成片

Laper
Laper

剧本策划到成片协作

AniShort
AniShort

AI短剧协同制作平台

Python temporal 的 Python SDK 生产案例

落雪吖_1274

落雪吖_1274

发布时间:2026-02-14 20:56:46

|

362人浏览过

|

来源于php中文网

原创

连不上是网络或配置问题,非SDK故障;需确认Server运行、显式指定地址(如WSL2用主机IP)、检查防火墙;workflow卡住多因activity未注册或异常;禁用time.sleep(),改用workflow.sleep();worker崩溃不丢状态,但需多实例与幂等设计。

python temporal 的 python sdk 生产案例

temporalio SDK 连不上本地 Temporal Server 怎么办

连不上基本是网络或配置错位,不是 SDK 本身问题。Temporal Python SDK 默认走 localhost:7233,但很多用户跑在 Docker 或 WSL 里,localhost 指向的不是 Server 所在网络栈。

  • 确认 Server 确实在运行:docker ps 看有没有 temporalio/auto-setup 容器,端口映射是否含 7233->7233
  • Python 代码里显式指定地址,别依赖默认:client = await Client.connect("127.0.0.1:7233")(Docker for Mac/Windows 可用;WSL2 则要用 Windows 主机 IP,比如 192.168.42.1:7233)
  • 防火墙或 antivirus 有时会拦截 7233,临时关掉试试;Mac 上还可能被 pfctl 规则阻断

workflow.execute() 卡住不返回,也没报错

这是最常被误判为“SDK hang”的场景——实际是 workflow 逻辑里调用了没注册的 activity,或 activity 函数抛了未捕获异常,导致 worker 无法完成任务。

  • 检查 worker 是否已启动且监听了对应 task queue:worker = Worker(client, task_queue="your-queue", workflows=[YourWorkflow], activities=[your_activity])
  • activity 函数必须是顶层函数或类方法,不能是闭包或 lambda;且参数类型需能被 dataclasses 或 pydantic.BaseModel 序列化
  • 加日志:在 activity 开头打 print("activity start"),如果没输出,说明根本没调度到 worker;如果输出了但没返回,大概率是 activity 内部阻塞(比如同步 HTTP 请求、死循环)

为什么 workflow 中不能用 time.sleep(),该用什么替代

time.sleep() 是线程阻塞,会卡住整个 workflow 线程,违反 Temporal 的“确定性重放”机制——重放时 sleep 时间不准,会导致 checksum 不一致,任务失败。

Python Hardener
Python Hardener

通过完整的安全审查、代码整洁重构、健壮的错误处理、正确的日志记录以及完整的文档字符串覆盖,强化 Python 脚本。

下载
  • 必须用 await asyncio.sleep(5)(异步等待),或更推荐 await workflow.sleep(5) ——后者由 SDK 控制,支持精确重放和跳过(测试时可加速)
  • 自定义定时逻辑(如“30 秒后发通知”)不要自己 while + sleep,改用 workflow.wait_condition() 或 schedule + timer,让 server 管理超时
  • 已有同步库(如 requests)要换成异步版(aiohttp),否则必须包在 workflow.run_sync() 里,但会损失可观测性和重放能力

production 环境下 worker 崩溃后 workflow 状态丢失吗

不会。Workflow 状态全存在 Temporal Server 的数据库里,worker 只是执行单元。worker 进程挂了,server 会在几秒内把 pending tasks 重新 dispatch 给其他存活 worker。

立即学习“Python免费学习笔记(深入)”;

  • 关键是要避免“单点 worker”:多个 worker 实例必须用相同 task_queue,且确保它们能并发处理同一类 activity(activity 函数得是幂等的)
  • worker 启动时建议加 health check 和 graceful shutdown:收到 SIGTERM 后调用 worker.stop(),等正在执行的 activity 完成再退出
  • 监控重点不是 worker 进程存活,而是 task_queue_pending_task_count 指标突增——说明 worker 处理不过来,或 activity 执行太慢

真正难调试的是 workflow 自身的非确定性:比如用了 random.random()、datetime.now()、或读了外部文件。这些在重放时值不同,会导致历史事件校验失败,Server 直接终止 workflow。这类问题不会报错,只会静默失败,得靠 workflow execution history 查 “DeterminismViolation” 事件。

热门AI工具

更多
豆包大模型

豆包大模型是一款由字节跳动推出的企业级大语言模型服务平台。

SkildArt
SkildArt Hot

SkildArt是一款AI文本写作工具,一站式 AI 视觉创作平台。

Loomy
Loomy Hot

一款AI工具,主要用于科大讯飞发布的桌面级 AI 助理,比 OpenClaw 更易用、更安全!,适合需要提升相关任务效率的用户。

切问学术

切问学术是一款AI论文写作工具,复旦大学NLP团队推出的AI学术智能体。

PixTV
PixTV Hot

PixTV是一款面向AIGC内容创作的AI视频生成工具。

小橡皮AI

一款AI工具,主要用于小橡皮一键去AI味,将机器味重的内容改得更有活人感,防止因为 AI 内容被平台打上 AI 标签,以及限流,适合需要提升相关任务效率的用户。

DeepSeek

DeepSeek是一款面向对话、写作、编程和推理场景的AI大模型工具。

WorkBuddy

一款AI办公效率工具,主要用于腾讯云推出的AI原生桌面智能体工作台,适合需要提升相关任务效率的用户。

函子Zion

一款支持AI搭建、可视化编辑和多端发布的全栈无代码开发平台。

相关专题

更多
python中print函数的用法
python中print函数的用法

python中print函数的语法是“print(value1, value2, ..., sep=' ', end=' ', file=sys.stdout, flush=False)”。本专题为大家提供print相关的文章、下载、课程内容,供大家免费下载体验。

3460

2023.09.27

python print用法与作用
python print用法与作用

本专题整合了python print的用法、作用、函数功能相关内容,阅读专题下面的文章了解更多详细教程。

269

2026.02.03

while的用法
while的用法

while的用法是“while 条件: 代码块”,条件是一个表达式,当条件为真时,执行代码块,然后再次判断条件是否为真,如果为真则继续执行代码块,直到条件为假为止。本专题为大家提供while相关的文章、下载、课程内容,供大家免费下载体验。

354

2023.09.25

lambda表达式
lambda表达式

Lambda表达式是一种匿名函数的简洁表示方式,它可以在需要函数作为参数的地方使用,并提供了一种更简洁、更灵活的编码方式,其语法为“lambda 参数列表: 表达式”,参数列表是函数的参数,可以包含一个或多个参数,用逗号分隔,表达式是函数的执行体,用于定义函数的具体操作。本专题为大家提供lambda表达式相关的文章、下载、课程内容,供大家免费下载体验。

1151

2023.09.15

python lambda函数
python lambda函数

本专题整合了python lambda函数用法详解,阅读专题下面的文章了解更多详细内容。

345

2025.11.08

Python lambda详解
Python lambda详解

本专题整合了Python lambda函数相关教程,阅读下面的文章了解更多详细内容。

674

2026.01.05

C++ Lambda 表达式与函数式编程
C++ Lambda 表达式与函数式编程

深入讲解 C++ Lambda 表达式与函数式编程范式,涵盖 Lambda 基础语法与返回值推导、值捕获与引用捕获的区别与陷阱、初始化捕获(C++14 广义捕获)、泛型 Lambda(auto 参数)、mutable 关键字修改捕获变量、std::function 类型擦除与函数包装、std::bind 参数绑定(及其被 Lambda 替代的趋势)、Lambda 在 STL 算法(sort/transform/for_each/remo

849

2026.05.06

Java 函数式接口与 Lambda 进阶技巧
Java 函数式接口与 Lambda 进阶技巧

在 Java Stream 基础之上进一步深入函数式编程,涵盖 @FunctionalInterface 注解与自定义函数式接口设计、四种方法引用(静态/实例/对象/构造器)的使用场景、Lambda 中的 effectively final 变量捕获规则、函数组合(andThen/compose)与柯里化技巧、Comparator 链式比较器构建、CompletableFuture 异步函数式编排、Reactor / RxJava 响应

448

2026.05.08

Go-Zero API开发使用教程
Go-Zero API开发使用教程

本专题聚焦Go-Zero的API开发,拆解.api描述文件的语法结构、路由与分组定义、参数绑定与校验规则,说明统一响应体、JWT鉴权、跨域与接口文档生成的落地方式,并给出网关聚合与接口测试的实践建议。

20

2026.11.12

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn