真实队列,模拟工作
生产者在当前应用中,消费者可选择 Worker 或外部 Python CLI。消费者用等待模拟 API 延迟,关闭网页不会停止后台处理。
选择一种负载,将真实任务投递到 Cloudflare Queues,观察消费、等待与重试。
在项目目录运行以下命令。CLI 需要配置 Cloudflare 凭证及回报凭证,详见 external-consumer/README.md。
cd external-consumer uv run --env-file ../.env --env-file .env consumer.py
CLI 停止时不会自动消费;重启后可继续拉取。一次拉取 1 条,消息租期 120 秒,未确认的消息到期后可重新投递。界面中的“成功”表示业务处理已记录,ACK 确认结果请查看 CLI 日志。
每次创建独立实验。同一种消费方式共用队列,三种消费方式使用独立队列。
选择上方任意场景并投递任务,或者打开一个历史实验。
生产者在当前应用中,消费者可选择 Worker 或外部 Python CLI。消费者用等待模拟 API 延迟,关闭网页不会停止后台处理。
Worker 每批最多 5 条,可自动并发;Python 每次拉取 1 条,由运行中的 CLI 控制消费速度。三种模式都不保证顺序。
模拟故障最多尝试 4 次,每次重试至少等待 3 秒。最终失败会记录并 ACK 结束,这是业务处理策略,不是死信队列。