cyanide 1.3.0

简介

此压力测试套件将尝试以不同方式破坏Celery工作进程，也可以用于为依赖于Celery基础设施的项目编写新的压力测试套件。

当前必须单独启动工作进程，并建议使用具有不同配置值的启动的工作进程重复套件。

想法包括

1. 默认，单进程

   $ celery -A cyanide worker -c 1

2. 默认，多进程

   $ celery -A cyanide worker -c 8

3. 频繁maxtasksperchild回收，单个子进程

   $ celery -A cyanide worker -c 1 --maxtasksperchild=1

4. 频繁自动缩放缩小 & maxtasksperchild，单个子进程

   $ AUTOSCALE_KEEPALIVE=0.01 celery -A cyanide worker \
   >   --autoscale=1,0 --maxtasksperchild=1

5. 频繁maxtasksperchild，多个子进程

   $ celery -A cyanide worker -c 8 --maxtasksperchild=1

6. 由时间限制终止的进程

   $ celery -A cyanide worker --time-limit=1

7. 频繁maxtasksperchild，单个子进程（晚确认）

   $ celery -A cyanide worker -c1 --maxtasksperchild=1 -Z acks_late

8. 使用eventlet池的工作进程

   启动工作进程，这里有千个绿色线程

   $ celery -A cyanide worker -c1000 -P eventlet

   在启动测试套件时必须激活green测试组

   $ celery cyanide -g green

9. 使用gevent池的工作进程

   启动工作进程，这里有千个绿色线程

   $ celery -A cyanide worker -c1000 -P gevent

   在启动测试套件时必须激活green测试组

   $ celery cyanide -g green

提示

包含--purge <celery worker --purge>参数以清除先前运行的作业是个好主意。

请注意，如果测试失败，压力客户端可能会挂起，因此当前此测试套件不适合自动运行。

配置模板

您可以使用任何celery -A cyanide命令或执行测试套件的celery cyanide命令的-Z命令行参数选择配置模板。

可用的模板有

• 默认

  使用AMQP作为代理，RPC作为结果后端，并使用JSON序列化任务和结果消息。

  代理和结果存储都预计将在本地运行。

• vagrant1

  使用celery vagrant up启动的虚拟机作为代理和结果后端（RabbitMQ）。

• vagrant1_redis

  使用celery vagrant up启动的虚拟机作为代理和结果后端（Redis）。

• redis

  使用Redis作为代理和结果后端。

• redistore

  仅使用Redis作为结果后端。

• acks_late

  全局启用晚确认。

• pickle

  使用pickle作为任务和结果的序列化器（也允许工作进程接收和处理pickle消息）

• confirms

  启用RabbitMQ发布者确认。

• events

  配置工作进程发送任务事件。

• proto1

  使用任务消息协议的1版本（4.0之前）

您可以通过运行命令查看任何模板的配置结果

$ celery -A cyanide report -Z redis

$ cyanide -Z redis

$ celery -A cyanide worker -Z redis

$ celery -A cyanide worker -Z redis,acks_late

测试套件选项

启动一个或多个工作实例后，您可以开始执行测试。

默认情况下，将执行完整的测试套件

$ celery cyanide

您也可以通过提供一个或多个名称作为参数来指定要运行的测试用例

$ celery cyanide revoketermfast revoketermslow

可以使用-l <celery cyanide -l>开关检索测试用例名称的完整列表

$ celery cyanide -l
.> 1) chain,
.> 2) chaincomplex,
.> 3) parentids_chain,
.> 4) parentids_group,
.> 5) manyshort,
.> 6) unicodetask,
.> 7) always_timeout,
.> 8) termbysig,
.> 9) timelimits,
.> 10) timelimits_soft,
.> 11) alwayskilled,
.> 12) alwaysexits,
.> 13) bigtasksbigvalue,
.> 14) bigtasks,
.> 15) smalltasks,
.> 16) revoketermfast,
.> 17) revoketermslow

您也可以从列表中的某个偏移量开始，例如，要跳过前两个测试，请使用 --offset=2 <celery cyanide --offset>

$ celery cyanide --offset=2

查看所有可用的命令行选项，请运行 celery cyanide --help

Vagrant

$ celery vagrant up

$ celery -A worker -Z vagrant1
$ celery cyanide -Z vagrant1

$ ssh $(celery vagrant sshargs)

$ celery vagrant halt

$ celery vagrant destroy

环境变量

$ CYANIDE_BROKER='amqp://' celery -A cyanide worker # ...
$ CYANIDE_BROKER='amqp://' celery cyanide

$ CYANIDE_BACKEND='amqp://' celery -A cyanide worker # ...
$ CYANIDE_BACKEND='amqp://' celery cyanide

$ CYANIDE_QUEUE='cyanide' celery -A cyanide worker # ...
$ CYANIDE_QUEUE='cyanide' celery cyanide

自定义套件

您可以定义自定义套件（查看 cyanide.suites.default 的源代码以获取灵感），并通过指定 celery cyanide -S 选项来告诉 cyanide 使用该套件。

$ celery cyanide -S proj.funtests:MySuite

安装

您可以通过 Python 包索引（PyPI）或从源代码安装 cyanide。

使用 pip 安装

$ pip install -U cyanide

$ tar xvfz cyanide-0.0.0.tar.gz
$ cd cyanide-0.0.0
$ python setup.py build
# python setup.py install

$ pip install https://github.com/celery/cyanide/zipball/master#egg=cyanide