Coze工作流搭建基础教程：从0到1构建基础工作流

工作空间名称：MyFirstWorkflow
描述：学习 Coze 工作流的基础教程
类型：个人/团队（根据需求选择）

{
  "工作流名称": "WeatherQueryBot",
  "描述": "自动查询天气信息并发送通知",
  "触发方式": "手动触发"
}

{
  "组件名称": "获取城市名称",
  "输入类型": "文本输入",
  "提示文本": "请输入要查询的城市名称（如：北京）",
  "必填": true,
  "默认值": "北京"
}

{
  "组件名称": "调用天气API",
  "请求方法": "GET",
  "URL": "https://api.openweathermap.org/data/2.5/weather",
  "请求头": {
    "Content-Type": "application/json"
  },
  "查询参数": {
    "q": "{{获取城市名称.output}}",
    "appid": "YOUR_API_KEY",
    "units": "metric",
    "lang": "zh_cn"
  }
}

function processWeatherData(input) {
  const data = JSON.parse(input);
  
  if (data.cod !== 200) {
    throw new Error(`查询失败：${data.message}`);
  }
  
  return {
    city: data.name,
    temperature: Math.round(data.main.temp),
    description: data.weather[0].description,
    humidity: data.main.humidity,
    windSpeed: data.wind.speed,
    icon: data.weather[0].icon
  };
}
 
// 调用函数处理数据
const result = processWeatherData({{调用天气API.output}});
return JSON.stringify(result);

{
  "组件名称": "发送天气通知",
  "消息类型": "富文本消息",
  "接收人": "@me",
  "消息内容": {
    "标题": "🌤️ 天气查询结果",
    "内容": "城市：{{处理返回数据.city}}\n温度：{{处理返回数据.temperature}}°C\n天气：{{处理返回数据.description}}\n湿度：{{处理返回数据.humidity}}%\n风速：{{处理返回数据.windSpeed}}m/s"
  }
}

// 在数据处理组件中添加错误处理
try {
  const data = JSON.parse(input);
  
  if (data.cod !== 200) {
    return {
      success: false,
      error: data.message,
      code: data.cod
    };
  }
  
  return {
    success: true,
    data: {
      city: data.name,
      temperature: Math.round(data.main.temp),
      // ... 其他字段
    }
  };
} catch (error) {
  return {
    success: false,
    error: error.message,
    code: 500
  };
}

{
  "组件类型": "条件分支",
  "条件表达式": "{{处理返回数据.temperature}} > 30",
  "分支1": {
    "名称": "高温天气",
    "下一步": "发送高温提醒"
  },
  "分支2": {
    "名称": "正常天气",
    "下一步": "发送普通通知"
  }
}

// 使用循环处理多个城市
const cities = ['北京', '上海', '广州', '深圳'];
const results = [];
 
for (const city of cities) {
  try {
    // 调用天气API的逻辑
    const weatherData = await getWeatherData(city);
    results.push({
      city: city,
      success: true,
      data: weatherData
    });
  } catch (error) {
    results.push({
      city: city,
      success: false,
      error: error.message
    });
  }
}
 
return JSON.stringify(results);

// 检查缓存
const cacheKey = `weather_${cityName}`;
const cachedData = await getCache(cacheKey);
 
if (cachedData && (Date.now() - cachedData.timestamp) < 300000) {
  // 5分钟内直接返回缓存数据
  return JSON.stringify(cachedData.data);
}
 
// 获取新数据并缓存
const freshData = await getWeatherData(cityName);
await setCache(cacheKey, {
  data: freshData,
  timestamp: Date.now()
});
 
return JSON.stringify(freshData);

{
  "子工作流名称": "通用API调用器",
  "输入参数": {
    "url": "string",
    "method": "string",
    "headers": "object",
    "params": "object"
  },
  "输出参数": {
    "status": "number",
    "data": "object",
    "error": "string"
  }
}

// 性能监控代码
const startTime = Date.now();
 
// 执行主要逻辑
await mainLogic();
 
const endTime = Date.now();
const duration = endTime - startTime;
 
// 记录性能指标
await logMetrics({
  workflowName: 'WeatherQueryBot',
  executionTime: duration,
  timestamp: new Date().toISOString(),
  status: 'success'
});

{
  "组件类型": "AI分析",
  "模型": "豆包大模型",
  "提示词": "分析以下客户工单内容，提取关键信息：\n{{工单内容}}\n\n请返回：\n1. 问题类型（技术/账单/产品/其他）\n2. 紧急程度（高/中/低）\n3. 建议处理方式",
  "输出格式": "JSON"
}

-- 更新工单状态
UPDATE tickets 
SET status = 'assigned', 
    assignee = '{{分配专员.output}}',
    priority = '{{情感分析.priority}}',
    updated_at = NOW()
WHERE id = '{{工单ID}}';
 
-- 插入处理记录
INSERT INTO ticket_logs (ticket_id, action, operator, timestamp)
VALUES ('{{工单ID}}', 'assigned', 'system', NOW());

{
  "通知渠道": "飞书群机器人",
  "消息模板": {
    "标题": "🎫 新工单分配通知",
    "内容": "工单 #{{工单ID}} 已分配给 {{分配专员.output}}\n客户情感：{{情感分析.sentiment}}\n处理优先级：{{情感分析.priority}}\n预计响应时间：{{SLA计算.output}}"
  }
}

// 在关键节点添加日志
console.log('=== 调试信息 ===');
console.log('输入数据：', input);
console.log('处理时间：', new Date().toISOString());
console.log('内存使用：', process.memoryUsage());