Cadence基础语法
03-Cadence基础语法
0 Cadence基础语法入门:流程编排语言的新星
Cadence是由Uber开发的一种领域特定语言(Domain-Specific Language,DSL),专门用于编写可扩展的长时间运行的业务流程。它是Temporal工作流引擎的核心组成部分,提供了一种简单yet强大的方式来处理分布式系统中的复杂工作流。在这篇博客中,我们将探索Cadence的基础语法,帮助你快速入门这个流程编排的新星。
1. 基本结构
Cadence工作流的基本结构包括工作流(Workflow)和活动(Activity)。工作流定义了业务流程的整体逻辑,而活动则是工作流中的具体任务。
工作流定义
func MyWorkflow(ctx workflow.Context, param string) error {
logger := workflow.GetLogger(ctx)
logger.Info("Workflow started", "param", param)
// 工作流逻辑
return nil
}
活动定义
func MyActivity(ctx context.Context, param string) (string, error) {
logger := activity.GetLogger(ctx)
logger.Info("Activity started", "param", param)
// 活动逻辑
return "Activity result", nil
}
2. 变量和数据类型
Cadence支持Go语言的基本数据类型,包括:
-
数值类型:int, float64 -
字符串:string -
布尔值:bool -
数组和切片 -
结构体
例如:
var (
count int
name string
isValid bool
numbers []int
)
type Person struct {
Name string
Age int
}
3. 控制流
Cadence支持常见的控制流语句,如条件语句和循环。
条件语句
if condition {
// 执行某些操作
} else if anotherCondition {
// 执行其他操作
} else {
// 默认操作
}
循环
for i := 0; i < 5; i++ {
// 重复执行的代码
}
// 或者使用range遍历
for index, value := range someSlice {
// 处理每个元素
}
4. 错误处理
Cadence使用Go风格的错误处理机制:
result, err := workflow.ExecuteActivity(ctx, MyActivity, param).Get(ctx, nil)
if err != nil {
return err
}
5. 并发和异步操作
Cadence提供了强大的并发和异步操作支持。
Future
Future用于处理异步操作的结果:
future := workflow.ExecuteActivity(ctx, MyActivity, param)
var result string
if err := future.Get(ctx, &result); err != nil {
return err
}
并行执行活动
使用workflow.Go
和workflow.Await
实现并行执行:
var result1, result2 string
workflow.Go(ctx, func(ctx workflow.Context) {
workflow.ExecuteActivity(ctx, Activity1).Get(ctx, &result1)
})
workflow.Go(ctx, func(ctx workflow.Context) {
workflow.ExecuteActivity(ctx, Activity2).Get(ctx, &result2)
})
workflow.Await(ctx, func() bool {
return result1 != "" && result2 != ""
})
6. 定时器和延迟
Cadence提供了定时器功能,用于实现延迟和超时:
// 延迟5秒
workflow.Sleep(ctx, 5*time.Second)
// 使用定时器
timer := workflow.NewTimer(ctx, 10*time.Second)
selector := workflow.NewSelector(ctx)
selector.AddFuture(timer, func(f workflow.Future) {
// 定时器触发后执行的操作
})
selector.Select(ctx)
7. 查询
Cadence允许定义查询来获取工作流的当前状态:
func (w *MyWorkflow) QueryState() (string, error) {
return w.currentState, nil
}
结语
这篇博客介绍了Cadence的基础语法,包括工作流和活动的定义、变量、控制流、错误处理、并发操作、定时器以及查询等核心概念。Cadence的强大之处在于它能够以一种简单直观的方式处理复杂的分布式系统问题,使得开发人员可以专注于业务逻辑而不是底层的并发和容错处理。
随着你对Cadence的深入学习,你会发现它还有许多高级特性,如saga模式、子工作流、本地活动等。这些特性使得Cadence能够适应各种复杂的业务场景。
希望这篇入门指南能够帮助你开始Cadence的学习之旅。随着实践的深入,你将会发现Cadence如何改变你对分布式系统编程的看法,并为你的项目带来新的可能性。
这篇技术博客涵盖了Cadence的基础语法和核心概念,包括:
-
基本结构(工作流和活动的定义) -
变量和数据类型 -
控制流(条件语句和循环) -
错误处理 -
并发和异步操作 -
定时器和延迟 -
查询
这些内容应该能给初学者一个良好的Cadence语法概览。博客的结构是从基础到稍微高级的特性逐步展开的,每个部分都包含了代码示例,以帮助读者更好地理解概念。
如果您想要对某个特定部分进行更深入的探讨,或者添加更多的示例,请告诉我。我也可以根据您的需求调整博客的风格或内容深度。
Cadence基础语法入门:流程编排语言的新星
Cadence是由Uber开发的一种领域特定语言(Domain-Specific Language,DSL),专门用于编写可扩展的长时间运行的业务流程。它是Temporal工作流引擎的核心组成部分,提供了一种简单yet强大的方式来处理分布式系统中的复杂工作流。在这篇博客中,我们将探索Cadence的基础语法,帮助你快速入门这个流程编排的新星。
1. 基本结构
Cadence工作流的基本结构包括工作流(Workflow)和活动(Activity)。工作流定义了业务流程的整体逻辑,而活动则是工作流中的具体任务。
工作流定义
func MyWorkflow(ctx workflow.Context, param string) error {
logger := workflow.GetLogger(ctx)
logger.Info("Workflow started", "param", param)
// 工作流逻辑
return nil
}
活动定义
func MyActivity(ctx context.Context, param string) (string, error) {
logger := activity.GetLogger(ctx)
logger.Info("Activity started", "param", param)
// 活动逻辑
return "Activity result", nil
}
2. 变量和数据类型
Cadence支持Go语言的基本数据类型,包括:
-
数值类型:int, float64 -
字符串:string -
布尔值:bool -
数组和切片 -
结构体
例如:
var (
count int
name string
isValid bool
numbers []int
)
type Person struct {
Name string
Age int
}
3. 控制流
Cadence支持常见的控制流语句,如条件语句和循环。
条件语句
if condition {
// 执行某些操作
} else if anotherCondition {
// 执行其他操作
} else {
// 默认操作
}
循环
for i := 0; i < 5; i++ {
// 重复执行的代码
}
// 或者使用range遍历
for index, value := range someSlice {
// 处理每个元素
}
4. 错误处理
Cadence使用Go风格的错误处理机制:
result, err := workflow.ExecuteActivity(ctx, MyActivity, param).Get(ctx, nil)
if err != nil {
return err
}
5. 并发和异步操作
Cadence提供了强大的并发和异步操作支持。
Future
Future用于处理异步操作的结果:
future := workflow.ExecuteActivity(ctx, MyActivity, param)
var result string
if err := future.Get(ctx, &result); err != nil {
return err
}
并行执行活动
使用workflow.Go
和workflow.Await
实现并行执行:
var result1, result2 string
workflow.Go(ctx, func(ctx workflow.Context) {
workflow.ExecuteActivity(ctx, Activity1).Get(ctx, &result1)
})
workflow.Go(ctx, func(ctx workflow.Context) {
workflow.ExecuteActivity(ctx, Activity2).Get(ctx, &result2)
})
workflow.Await(ctx, func() bool {
return result1 != "" && result2 != ""
})
6. 定时器和延迟
Cadence提供了定时器功能,用于实现延迟和超时:
// 延迟5秒
workflow.Sleep(ctx, 5*time.Second)
// 使用定时器
timer := workflow.NewTimer(ctx, 10*time.Second)
selector := workflow.NewSelector(ctx)
selector.AddFuture(timer, func(f workflow.Future) {
// 定时器触发后执行的操作
})
selector.Select(ctx)
7. 查询
Cadence允许定义查询来获取工作流的当前状态:
func (w *MyWorkflow) QueryState() (string, error) {
return w.currentState, nil
}
获取更多干货内容,记得关注我哦。
本文由 mdnice 多平台发布
相关文章:
Cadence基础语法
03-Cadence基础语法 0 Cadence基础语法入门:流程编排语言的新星 Cadence是由Uber开发的一种领域特定语言(Domain-Specific Language,DSL),专门用于编写可扩展的长时间运行的业务流程。它是Temporal工作流引擎的核心组…...

GAMES101虚拟机使用教程与探讨
写在前面 环境配置请参考作业0的pdf,本文章主要对于配置好环境后怎么使用以及遇到的问题进行探讨(要是有更方便的使用方式欢迎在评论区讨论),自己刚开始用的时候也折腾了好久,希望能为后来学习的小伙伴节约一点工具使…...

王道考研编程题总结
我还在完善中,边复习边完善(这个只是根据我自身总结的) 一、 线性表 1. 结构体 #define MaxSize 40 typedef struct{ElemType data[MaxSize];int length; }SqList 2. 编程题 1. 删除最小值 题意 :从顺序表中删除…...
算法2--滑动窗口
滑动窗口 滑动窗口经典例题长度最小的子数组无重复字符的最长子串[最大连续1的个数 III](https://leetcode.cn/problems/max-consecutive-ones-iii/description/)[将 x 减到 0 的最小操作数](https://leetcode.cn/problems/minimum-operations-to-reduce-x-to-zero/description…...

pycharm或conda中配置镜像源
文章目录 1. 为什么要配置镜像源2. pycharm配置2.1使用pip配置国内镜像源2.2 Pycharm中更改镜像源 3.conda配置镜像源3.1 使用conda命令3.2 文件所在位置(进行增删)3.3 conda常用的几个命令 参考文献 1. 为什么要配置镜像源 由于Python在下载包时&#…...
C#基础之方法
文章目录 1 方法1.1 定义方法1.2 参数传递1.2.1 按值传递参数1.2.2 按引用传递参数1.2.3 按输出传递参数1.2.4 可变参数 params1.2.5 具名参数1.2.6 可选参数 1.3 匿名方法1.3.1 Lambda 表达式1.3.1.1 定义1.3.1.2 常用类型1.3.1.3 Lambda 表达式与 LINQ1.3.1.4 Lambda 表达式的…...

JVM 性能调优 -- JVM常用调优工具【jps、jstack、jmap、jstats 命令】
前言: 前面我们分析怎么去预估系统资源,怎么去设置 JVM 参数以及怎么去看 GC 日志,本篇我们分享一些常用的 JVM 调优工具,我们在进行 JVM 调优的时候,通常需要借助一些工具来对系统的进行相关分析,从而确定…...
PostgreSQL 三种关库模式
PostgreSQL 三种关库模式 基础信息 OS版本:Red Hat Enterprise Linux Server release 7.9 (Maipo) DB版本:16.2 pg软件目录:/home/pg16/soft pg数据目录:/home/pg16/data 端口:5777PostgreSQL 提供了三种关库模式&…...

《运放秘籍》第二部:仪表放大器专项知识点总结
一、差分放大器与仪表放大器的讨论 1.1. 仪放的前世今生——差分放大器原理? 1.2. 差分放大的原理 1.3. 差分放大器检测电流 1.4. 差分放大器端一:输入阻抗 1.5. 差分放大器端二:共模抑制比 1.6. 为什么关注输入阻抗?共模抑…...

C++STL之vector(超详细)
CSTL之vector 1.vector基本介绍2.vector重要接口2.1.构造函数2.2.迭代器2.3.空间2.3.1.resize2.3.2.capacity 2.4.增删查找 3.迭代器失效4.迭代器分类 🌟🌟hello,各位读者大大们你们好呀🌟🌟 🚀Ὠ…...
ubuntu环境下安装electron环境,并快速打包
1.配置镜像源 关闭防火墙,命令:sudo ufw disable 1.1配置国内镜像源: vim /etc/apt/source.list deb https://mirrors.aliyun.com/ubuntu/ jammy main restricted universe multiversedeb-src https://mirrors.aliyun.com/ubuntu/ jammy main…...
【Pytorch】优化器(Optimizer)模块‘torch.optim’
torch.optim 是 PyTorch 中提供的优化器(Optimizer)模块,用于优化神经网络模型的参数,更新网络权重,使得模型在训练过程中最小化损失函数。它提供了多种常见的优化算法,如 梯度下降法(SGD&#…...

API平台建设之路:从0到1的实践指南
在这个互联网蓬勃发展的时代,API已经成为连接各个系统、服务和应用的重要纽带。搭建一个优质的API平台不仅能为开发者提供便利,更能创造可观的商业价值。让我们一起探讨如何打造一个成功的API平台。 技术架构是API平台的根基。选择合适的技术栈对平台的…...

【Flink-scala】DataStream编程模型之窗口计算-触发器-驱逐器
DataStream API编程模型 1.【Flink-Scala】DataStream编程模型之数据源、数据转换、数据输出 2.【Flink-scala】DataStream编程模型之 窗口的划分-时间概念-窗口计算程序 文章目录 DataStream API编程模型前言1.触发器1.1 代码示例 2.驱逐器2.1 代码示例 总结 前言 本小节我想…...

信号灯集以及 P V 操作
一、信号灯集 1.1 信号灯集的概念 信号灯集是进程间同步的一种方式。 信号灯集创建后,在信号灯集内部会有很多个信号灯。 每个信号灯都可以理解为是一个信号量。 信号灯的编号是从0开始的。 比如A进程监视0号灯,B进程监视1号灯。 0号灯有资源&…...
在 Flutter app 中,通过视频 URL 下载视频到手机相册
在 Flutter app 中,通过视频 URL 下载视频到手机相册可以通过以下步骤实现: 1. 添加依赖 使用 dio 下载文件,结合 path_provider 获取临时存储路径,以及 gallery_saver 将文件保存到相册。 在 pubspec.yaml 中添加以下依赖&…...
Nature Methods | 人工智能在生物与医学研究中的应用
Nature Methods | 人工智能在生物与医学研究中的应用 生物研究中的深度学习 随着人工智能(AI)技术的迅速发展,尤其是深度学习和大规模预训练模型的出现,AI在生物学研究中的应用正在经历一场革命。从基因组学、单细胞组学到癌症生…...

Axure PR 9 随机函数 设计交互
大家好,我是大明同学。 这期内容,我们将深入探讨Axure中随机函数的用法。 随机函数 创建随机函数所需的元件 1.打开一个新的 RP 文件并在画布上打开 Page 1。 2.在元件库中拖出一个矩形元件。 3.选中矩形元件,样式窗格中,将…...

【人工智能基础05】决策树模型
文章目录 一. 基础内容1. 决策树基本原理1.1. 定义1.2. 表示成条件概率 2. 决策树的训练算法2.1. 划分选择的算法信息增益(ID3 算法)信息增益比(C4.5 算法)基尼指数(CART 算法)举例说明:计算各个…...

【人工智能基础03】机器学习(练习题)
文章目录 课本习题监督学习的例子过拟合和欠拟合常见损失函数,判断一个损失函数的好坏无监督分类:kmeans无监督分类,Kmeans 三分类问题变换距离函数选择不同的起始点 重点回顾1. 监督学习、半监督学习和无监督学习的定义2. 判断学习场景3. 监…...
挑战杯推荐项目
“人工智能”创意赛 - 智能艺术创作助手:借助大模型技术,开发能根据用户输入的主题、风格等要求,生成绘画、音乐、文学作品等多种形式艺术创作灵感或初稿的应用,帮助艺术家和创意爱好者激发创意、提高创作效率。 - 个性化梦境…...

国防科技大学计算机基础课程笔记02信息编码
1.机内码和国标码 国标码就是我们非常熟悉的这个GB2312,但是因为都是16进制,因此这个了16进制的数据既可以翻译成为这个机器码,也可以翻译成为这个国标码,所以这个时候很容易会出现这个歧义的情况; 因此,我们的这个国…...

调用支付宝接口响应40004 SYSTEM_ERROR问题排查
在对接支付宝API的时候,遇到了一些问题,记录一下排查过程。 Body:{"datadigital_fincloud_generalsaas_face_certify_initialize_response":{"msg":"Business Failed","code":"40004","sub_msg…...
Robots.txt 文件
什么是robots.txt? robots.txt 是一个位于网站根目录下的文本文件(如:https://example.com/robots.txt),它用于指导网络爬虫(如搜索引擎的蜘蛛程序)如何抓取该网站的内容。这个文件遵循 Robots…...
Rapidio门铃消息FIFO溢出机制
关于RapidIO门铃消息FIFO的溢出机制及其与中断抖动的关系,以下是深入解析: 门铃FIFO溢出的本质 在RapidIO系统中,门铃消息FIFO是硬件控制器内部的缓冲区,用于临时存储接收到的门铃消息(Doorbell Message)。…...

让回归模型不再被异常值“带跑偏“,MSE和Cauchy损失函数在噪声数据环境下的实战对比
在机器学习的回归分析中,损失函数的选择对模型性能具有决定性影响。均方误差(MSE)作为经典的损失函数,在处理干净数据时表现优异,但在面对包含异常值的噪声数据时,其对大误差的二次惩罚机制往往导致模型参数…...

基于TurtleBot3在Gazebo地图实现机器人远程控制
1. TurtleBot3环境配置 # 下载TurtleBot3核心包 mkdir -p ~/catkin_ws/src cd ~/catkin_ws/src git clone -b noetic-devel https://github.com/ROBOTIS-GIT/turtlebot3.git git clone -b noetic https://github.com/ROBOTIS-GIT/turtlebot3_msgs.git git clone -b noetic-dev…...
QT3D学习笔记——圆台、圆锥
类名作用Qt3DWindow3D渲染窗口容器QEntity场景中的实体(对象或容器)QCamera控制观察视角QPointLight点光源QConeMesh圆锥几何网格QTransform控制实体的位置/旋转/缩放QPhongMaterialPhong光照材质(定义颜色、反光等)QFirstPersonC…...

Git 3天2K星标:Datawhale 的 Happy-LLM 项目介绍(附教程)
引言 在人工智能飞速发展的今天,大语言模型(Large Language Models, LLMs)已成为技术领域的焦点。从智能写作到代码生成,LLM 的应用场景不断扩展,深刻改变了我们的工作和生活方式。然而,理解这些模型的内部…...
MySQL 索引底层结构揭秘:B-Tree 与 B+Tree 的区别与应用
文章目录 一、背景知识:什么是 B-Tree 和 BTree? B-Tree(平衡多路查找树) BTree(B-Tree 的变种) 二、结构对比:一张图看懂 三、为什么 MySQL InnoDB 选择 BTree? 1. 范围查询更快 2…...