Bogdanp / django_dramatiq

A Django app that integrates with Dramatiq.
https://dramatiq.io
Other
331 stars 77 forks source link

Heartbeat error with RabbitmqBroker #145

Open legioz opened 1 year ago

legioz commented 1 year ago

I keep receiving this logs, when using the config below in settings.py:

   | 2023-05-06 03:08:45.483558-03:00 [error] <0.1194.0> closing AMQP connection <0.1194.0> (172.28.0.5:45310 -> 172.28.0.6:5672):
   | 2023-05-06 03:08:45.483558-03:00 [error] <0.1194.0> missed heartbeats from client, timeout: 60s
DRAMATIQ_BROKER = {
    "BROKER": "dramatiq.brokers.rabbitmq.RabbitmqBroker",
    "OPTIONS": {
        "url": BROKER_URL,
    },
    "MIDDLEWARE": [
        "dramatiq.middleware.Prometheus",
        "dramatiq.middleware.AgeLimit",
        "dramatiq.middleware.TimeLimit",
        "dramatiq.middleware.Callbacks",
        "dramatiq.middleware.Retries",
        "django_dramatiq.middleware.DbConnectionsMiddleware",
        "django_dramatiq.middleware.AdminMiddleware",
        "periodiq.PeriodiqMiddleware",
    ],
}

If I pass the value heatbeat:30 in OPTIONS I get an error saying url is not valid with pika configs