danihodovic / celery-exporter

A Prometheus exporter for Celery metrics
MIT License
385 stars 85 forks source link

Statistics in Grafana not working #251

Closed Podolyan98 closed 1 year ago

Podolyan98 commented 1 year ago

I deployed the exporter, but the statistics in Grafana do not work.

Prometheus:

  - job_name: "Celery"
    static_configs:
    - targets: ["10.50.0.1:9808"]

curl http://10.50.0.1:9808/metrics:

# HELP celery_task_sent_total Sent when a task message is published.
# TYPE celery_task_sent_total counter
celery_task_sent_total{hostname="instance32",name="app.email_services.send_email",queue_name="celery"} 11.0
celery_task_sent_total{hostname="instance32",name="app.tasks.search_for_new_available_staff",queue_name="celery"} 0.0
celery_task_sent_total{hostname="instance32",name="app.tasks.search_for_new_available_shifts",queue_name="celery"} 0.0
celery_task_sent_total{hostname="instance32",name="app.tasks.search_for_expired_shifts",queue_name="celery"} 0.0
celery_task_sent_total{hostname="instance32",name="app.tasks.search_for_unconfirmed_shifts",queue_name="celery"} 0.0
celery_task_sent_total{hostname="instance32",name="celery.backend_cleanup",queue_name="celery"} 0.0
# HELP celery_task_sent_created Sent when a task message is published.
# TYPE celery_task_sent_created gauge
celery_task_sent_created{hostname="instance32",name="app.email_services.send_email",queue_name="celery"} 1.6855433891455138e+09
celery_task_sent_created{hostname="instance32",name="app.tasks.search_for_new_available_staff",queue_name="celery"} 1.6855776002541292e+09
celery_task_sent_created{hostname="instance32",name="app.tasks.search_for_new_available_shifts",queue_name="celery"} 1.6855776002659323e+09
celery_task_sent_created{hostname="instance32",name="app.tasks.search_for_expired_shifts",queue_name="celery"} 1.6855776002684853e+09
celery_task_sent_created{hostname="instance32",name="app.tasks.search_for_unconfirmed_shifts",queue_name="celery"} 1.685577600423241e+09
celery_task_sent_created{hostname="instance32",name="celery.backend_cleanup",queue_name="celery"} 1.68559200013313e+09
# HELP celery_task_received_total Sent when the worker receives a task.
# TYPE celery_task_received_total counter
celery_task_received_total{hostname="instance32",name="app.email_services.send_email",queue_name="celery"} 13.0
celery_task_received_total{hostname="instance32",name="app.tasks.search_for_new_available_staff",queue_name="celery"} 1.0
celery_task_received_total{hostname="instance32",name="app.tasks.search_for_new_available_shifts",queue_name="celery"} 1.0
celery_task_received_total{hostname="instance32",name="app.tasks.search_for_expired_shifts",queue_name="celery"} 1.0
celery_task_received_total{hostname="instance32",name="app.tasks.search_for_unconfirmed_shifts",queue_name="celery"} 1.0
celery_task_received_total{hostname="instance32",name="celery.backend_cleanup",queue_name="celery"} 1.0
# HELP celery_task_received_created Sent when the worker receives a task.
# TYPE celery_task_received_created gauge
celery_task_received_created{hostname="instance32",name="app.email_services.send_email",queue_name="celery"} 1.6855433895425422e+09
celery_task_received_created{hostname="instance32",name="app.tasks.search_for_new_available_staff",queue_name="celery"} 1.6855776002541919e+09
celery_task_received_created{hostname="instance32",name="app.tasks.search_for_new_available_shifts",queue_name="celery"} 1.685577600265991e+09
celery_task_received_created{hostname="instance32",name="app.tasks.search_for_expired_shifts",queue_name="celery"} 1.6855776002685437e+09
celery_task_received_created{hostname="instance32",name="app.tasks.search_for_unconfirmed_shifts",queue_name="celery"} 1.6855776004233027e+09
celery_task_received_created{hostname="instance32",name="celery.backend_cleanup",queue_name="celery"} 1.685592000133328e+09
# HELP celery_task_started_total Sent just before the worker executes the task.
# TYPE celery_task_started_total counter
celery_task_started_total{hostname="instance32",name="app.email_services.send_email",queue_name="celery"} 13.0
celery_task_started_total{hostname="instance32",name="app.tasks.search_for_new_available_staff",queue_name="celery"} 1.0
celery_task_started_total{hostname="instance32",name="app.tasks.search_for_new_available_shifts",queue_name="celery"} 1.0
celery_task_started_total{hostname="instance32",name="app.tasks.search_for_expired_shifts",queue_name="celery"} 1.0
celery_task_started_total{hostname="instance32",name="app.tasks.search_for_unconfirmed_shifts",queue_name="celery"} 1.0
celery_task_started_total{hostname="instance32",name="celery.backend_cleanup",queue_name="celery"} 1.0
# HELP celery_task_started_created Sent just before the worker executes the task.
# TYPE celery_task_started_created gauge
celery_task_started_created{hostname="instance32",name="app.email_services.send_email",queue_name="celery"} 1.6855433895425956e+09
celery_task_started_created{hostname="instance32",name="app.tasks.search_for_new_available_staff",queue_name="celery"} 1.6855776002542472e+09
celery_task_started_created{hostname="instance32",name="app.tasks.search_for_new_available_shifts",queue_name="celery"} 1.6855776002660449e+09
celery_task_started_created{hostname="instance32",name="app.tasks.search_for_expired_shifts",queue_name="celery"} 1.6855776002685978e+09
celery_task_started_created{hostname="instance32",name="app.tasks.search_for_unconfirmed_shifts",queue_name="celery"} 1.6855776004233575e+09
celery_task_started_created{hostname="instance32",name="celery.backend_cleanup",queue_name="celery"} 1.6855920001335135e+09

Celery / Tasks / Overview:

image

adinhodovic commented 1 year ago

Try the new dashboards which have a filter for the job: