真实队列,模拟工作
生产者在当前应用中,消费者可选择 Worker 或外部 Python CLI。消费者用等待模拟 API 延迟,关闭网页不会停止后台处理。
选择一种负载,将真实任务投递到 Cloudflare Queues,观察消费、等待与重试。
先投递任务,再运行下方命令。api-consumer/.env 只需 APP_URL 和 CONSUMER_TOKEN。
cd api-consumer uv run --env-file .env consumer.py
应用负责领取 Queue 消息、提供任务内容和确认结果。任务须在领取后 45 秒内提交;CLI 中断后,消息在约 60 秒租期到期后可重新投递。完成接口先保存结果,再确认 ACK;CLI 日志显示确认结果。
每次创建独立实验。同一种消费方式共用队列,三种消费方式使用独立队列。
选择上方任意场景并投递任务,或者打开一个历史实验。
生产者在当前应用中,消费者可选择 Worker 或外部 Python CLI。消费者用等待模拟 API 延迟,关闭网页不会停止后台处理。
Worker 每批最多 5 条,可自动并发;Python 每次拉取 1 条,由运行中的 CLI 控制消费速度。三种模式都不保证顺序。
模拟故障最多尝试 4 次,每次重试至少等待 3 秒。最终失败会记录并 ACK 结束,这是业务处理策略,不是死信队列。