Cadence技能功能入门指南：从零构建高效工作流

1次阅读

共计 2590 个字符，预计需要花费 7 分钟才能阅读完成。

Cadence 是一个分布式工作流编排引擎，而技能 (Skill) 功能是其核心特性之一。简单来说，技能功能允许你将复杂的业务逻辑封装成可重用的组件，就像乐高积木一样可以灵活拼装。

使用技能功能的三大优势：

代码复用：避免重复造轮子，相同的业务逻辑只需开发一次
降低复杂度：将大工作流拆解为小技能，便于维护和调试
提高可靠性：内置重试机制和超时处理，增强系统容错能力

graph TD
    A[工作流] -->| 调用 | B(技能)
    B --> C{执行逻辑}
    C -->| 成功 | D[返回结果]
    C -->| 失败 | E[自动重试]

技能接口(Skill Interface)：定义技能的输入输出规范
技能实现(Skill Implementation)：包含实际业务逻辑
执行上下文(Context)：提供运行时环境信息
重试策略(Retry Policy)：控制失败时的自动重试行为

安装 Cadence 服务端和 CLI 工具
配置 Go/Python 开发环境
初始化 Cadence 客户端连接

以 Python 为例，定义一个简单的邮件发送技能：

from cadence.worker import Worker
from cadence.activity import activity_method

# 定义技能接口
@activity_method(task_list="EmailTaskList", schedule_to_close_timeout_seconds=60)
class EmailSkill:
    @staticmethod
    async def send(subject: str, recipient: str, body: str) -> bool:
        """
        :param subject: 邮件主题
        :param recipient: 收件人邮箱
        :param body: 邮件正文
        :return: 发送是否成功
        """
        # 实际发送逻辑实现
        return True

from cadence.workflow import workflow_method, Workflow

@workflow_method(execution_start_to_close_timeout_seconds=300,
                 task_list="OrderProcessing")
class OrderWorkflow:
    def process_order(self, order_id: str):
        # 调用邮件技能
        email_result = yield EmailSkill.send(
            subject="订单确认",
            recipient="customer@example.com",
            body=f"您的订单 {order_id} 已受理"
        )
        if not email_result:
            # 错误处理逻辑
            pass

以下是 Go 语言的完整实现示例：

package main

import (
    "context"
    "go.uber.org/cadence/activity"
    "go.uber.org/cadence/workflow"
)

// 定义技能接口
const EmailSkillName = "emailSkill"

type EmailSkill struct {
    Subject   string
    Recipient string
    Body      string
}

// 技能实现
func EmailActivity(ctx context.Context, skill EmailSkill) (bool, error) {logger := activity.GetLogger(ctx)
    logger.Info("Sending email", skill)

    // 实际发送逻辑
    return true, nil
}

// 工作流集成
func OrderWorkflow(ctx workflow.Context, orderID string) error {
    ao := workflow.ActivityOptions{
        ScheduleToStartTimeout: time.Minute,
        StartToCloseTimeout:   time.Minute,
        RetryPolicy: &cadence.RetryPolicy{
            InitialInterval:    time.Second,
            BackoffCoefficient: 2.0,
            MaximumInterval:    time.Minute,
        },
    }
    ctx = workflow.WithActivityOptions(ctx, ao)

    // 调用技能
    var success bool
    err := workflow.ExecuteActivity(ctx, EmailActivity, EmailSkill{
        Subject:   "订单确认",
        Recipient: "customer@example.com",
        Body:      fmt.Sprintf("您的订单 %s 已受理", orderID),
    }).Get(ctx, &success)

    if err != nil {return err}

    return nil
}