我怎样才能杀死rabbitmq中的进程？

Question

我正在用 rabbit mq 测试 AI 模型。
由于使用AI模型的过程比较繁重，所以我使用rabbit mq来控制任务顺序。
问题是消耗后杀死回调函数。
比如rabbit mq中有3个task(A,B,C依次)

1. 任务A正在消耗，回调函数（包括AI模型）为运行
2. 任务 B,C 正在等待 basic_ack 到达
3. 我要先取消任务A、B和分析C

在这种情况下，

1. 如何终止进程（任务 A），
2. 删除兔子MQ中的消息B

Answer 1

我找到了路，但不确定路是否正确。 使用另一个队列接收来自 rabbitmq 的所有消息 create_task 通过使用 asyncio 在我想要的时候取消 它运作良好，只有所有功能都是 asyncronose