关于使用k6进行Temporal Workflows负载测试的咨询及参考资料请求

完全可以使用k6工具对Temporal Workflows进行负载测试。k6的自定义脚本能力可以无缝对接Temporal的客户端SDK，模拟大量并发客户端发起Workflow执行请求，以此验证Temporal集群、Worker以及关联业务逻辑在高负载下的稳定性与性能表现。

实现步骤 #

1. 准备依赖 #

如果使用JavaScript/TypeScript编写k6测试脚本，先在项目中安装Temporal Node.js客户端SDK：

npm install @temporalio/client

确保k6配置支持ES模块（可在k6.json中设置"esmodules": true）。

2. 编写k6测试脚本 #

核心逻辑是在k6的虚拟用户函数中，初始化Temporal客户端并发起Workflow执行请求。示例脚本如下：

import { Client } from '@temporalio/client';
import { sleep } from 'k6';

// 测试配置：虚拟用户数、测试时长
export const options = {
  vus: 100,
  duration: '1m',
};

export default async function () {
  // 初始化Temporal客户端
  const client = new Client({
    connection: {
      address: 'temporal-server:7233', // 替换为你的Temporal服务地址
    },
  });

  try {
    // 启动指定的Workflow
    const workflowHandle = await client.workflow.start('SampleWorkflow', {
      taskQueue: 'sample-task-queue',
      args: ['test-payload'], // Workflow所需的入参
      workflowId: `test-workflow-${__VU}-${__ITER}`, // 生成唯一Workflow ID
    });
    console.log(`Started workflow: ${workflowHandle.workflowId}`);

    // 可选：等待Workflow执行完成并获取结果（根据测试场景选择）
    // const result = await workflowHandle.result();
    // console.log(`Workflow result: ${result}`);
  } catch (error) {
    console.error(`Failed to start workflow: ${error.message}`);
  }

  // 控制请求间隔，避免瞬间压垮服务
  sleep(0.5);
}

3. 测试关键注意事项 #

• 根据目标负载调整vus（虚拟用户数）和duration（测试时长）参数，逐步加压观察系统表现
• 确保Temporal集群的Worker数量、Task Queue配置、数据库资源能匹配测试负载，避免因集群自身瓶颈影响测试结果
• 利用k6内置的指标（如http_req_duration、checks）监控请求成功率、响应时间等核心指标，分析性能瓶颈
• 若需测试Workflow全生命周期性能，可添加等待Workflow完成的逻辑，但注意这会延长单虚拟用户的执行周期

参考资料要点 #

• Temporal官方文档的Client API章节：详细讲解了通过SDK发起Workflow、查询Workflow状态等操作的细节
• k6官方文档的JavaScript脚本指南与并发测试最佳实践：介绍如何配置虚拟用户、自定义测试逻辑以及指标分析方法
• Temporal官方负载测试建议：重点关注Worker水平缩放策略、Task Queue分区配置、数据库连接池优化等方向

内容的提问来源于stack exchange，提问作者Himanshu Pandey