pika - TTL 是否在 Pika 中实现？

Question

我希望我的队列丢弃在特定时间内未处理的消息。

我已经通过记录发布时间在消费者中做到了这一点。然而，在没有人订阅的情况下，队列最好简单地丢弃陈旧的消息。

我可以在 Pika 的消息中设置过期时间 (TTL) 吗？ RabbitMQ 文档对此进行了讨论，但我在 Pika 文档中没有看到 TTL 引用。

Answer 1

您可以使用 BasicProperties 对象上的过期标志设置每条消息的 TTL，如 pika 文档 here 中所示。 .

使用它看起来像这样。

channel.basic_publish(
    exchange='',
    routing_key='hello_world',
    properties=pika.BasicProperties(
        expiration='60000',
    ),
    body='my message'
)

请记住， expiration策略使用毫秒作为字符串表示，因此 60000将转化为 60 秒。

您可以阅读更多关于基于消息的 TTL 及其警告 here .