使用 temporal 构建工作流时,对于长时间任务是在 workflow 里轮询好还是 activity 里轮询好?

96 天前
 Grayan

rt ,现在有一个文本下发的任务,选中设备,设置执行时间。设备上线后,给设备下发文本指令。在工作流中,需要 在 for 循环中遍历设备列表,对在线的设备下发指令,记录结果,直到所有设备下发完成,任务结束。执行时间可能是几天甚至一两周。

刚开始学习使用 temporal ,现在想到有两种方案:

  1. 在 workflow 中使用 for 循环执行 activity ,每次 activity 返回是否完成的标签,然后使用 workflow.sleep 设置间隔时间,直到返回 true 则任务执行完成。

  2. 直接在 activity 中使用 for select 循环执行直到所有设备完成结束 activity ,任务完成。

现要求任务可以取消、可持久化、worker 断开重启后可以继续执行。请问下我这种长时间任务正确的做法是该使用哪种模式?

915 次点击
所在节点    程序员
1 条回复
masterclock
96 天前
如果用 2 ,这个 Activity 失败重试的话,就要全部设备设备都再来过了

感觉不如每个设备的下发任务一个 workflow

这是一个专为移动设备优化的页面(即为了让你能够在 Google 搜索结果里秒开这个页面),如果你希望参与 V2EX 社区的讨论,你可以继续到 V2EX 上打开本讨论主题的完整版本。

https://www.v2ex.com/t/1053761

V2EX 是创意工作者们的社区,是一个分享自己正在做的有趣事物、交流想法,可以遇见新朋友甚至新机会的地方。

V2EX is a community of developers, designers and creative people.

© 2021 V2EX