Есть ли способ зарегистрировать в памяти тревогу rabbitmq

Question

Мое приложение только что заморозилось, потому что использование памяти rabbitmq превысило его порог.

Я использую pika и pyrabbit в качестве оболочки Python для обработки каналов и соединений.Я брожу, если есть способ, которым мой процесс будет регистрироваться на что-то и получать уведомление, когда это событие происходит (и, надеюсь, даже немного раньше, чем это происходит).

Answer 1

При использовании rabbitpy вы можете проверить, установлен ли флаг заблокирован .Этот флаг означает, что соединение блокируется из-за нехватки ресурсов (скорее всего, из-за нехватки памяти).

with rabbitpy.Connection('amqp://guest:guest@localhost:5672/%2f') as conn:
    print(conn.blocked)

например

while conn.blocked:
    time.sleep(0.1)  # wait until connection is unblocked