首页  

temporal学习笔记     所属分类 temporal 浏览量 841
分布式 可扩展 持久且高度可用的任务编排引擎
工作流  活动
官方组件示意图
Start(client) TemporalServer Worker Bank(DB)

Start          工作流的创建者/发起者
TemporalServer 存储工作流的数据、状态 
Worker         进行逻辑处理的执行者
Bank           可理解为DB

流程描述
启动Temporal Server
启动Worder监听TS,循环获取待执行的工作流
Start创建一个工作流,封装参数,调用sdk的api(rpc)发送到TS
Worker拉取工作流开始执行

worker 执行Activity和Workflow并将结果返回给TS
一个Wokeflow包含多个Activity,对Activity进行编排,多个Activity可以并行,也可以同步

tctl  temporal ctl  temporal命令行工具
temporal工程下执行 make bins  编译生成 tctl 可执行文件

创建namespace
$ ./tctl --ad yourip:7233 --namespace yournamespace n re --gd true --cl active standby
查看工作流信息
./tctl --ad yourip:7233 --namespace yournamespace workflow show -w workflow_id_id

./tctl -h
namespace, n       Operate Temporal namespace
workflow, wf       Operate Temporal workflow
activity, act      Operate activities of workflow
taskqueue, tq      Operate Temporal task queue
batch              Batch operation on a list of workflows from query.
admin, adm         Run admin operation
cluster, cl        Operate Temporal cluster
dataconverter, dc  Operate Custom Data Converter
help, h            Shows a list of commands or help for one command
   
./tctl n re -h
--retention value, --rd value                   Workflow execution retention
--active_cluster value, --ac value              Active cluster name
--clusters value, --cl value                    Clusters
--global_namespace value, --gd value            Flag to indicate whether namespace is a global namespace

上一篇     下一篇
idea jdk 版本设置

Akka Quickstart 例子说明

grpc jar版本不匹配问题处理实例

Temporal Server architecture

temporal 监控指标

使用arthas 观察 temporal worker grpc 方法调用