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 方法调用