celery-exporter
celery-exporter copied to clipboard
OvalMoney
Prometheus metrics exporter for Celery
Hello, was doing upgrade today to python version `3.9` and it looks like wheel file for Python version `3.9` is not present in pypi: https://pypi.org/project/celery-exporter/#files Not sure if this is...
I am using celery=5.0.2 and django=2.2.2. I have enabled these two settings in my django app: CELERY_WORKER_SEND_TASK_EVENTS = True CELERY_TASK_SEND_SENT_EVENT = True I am using the docker image and passing...
get_conf function only checks routes that have queue as a key Added --route-options to added custom route if defined in celery
I have 2 different kinds of celery workers each executing tasks from its own queue. Can I get celery_workers count for each worker type(using queue name) by celery-exporter?
Hiya, I'm just wondering how easy/hard would it be to implement number of tasks in a queue (to detect whether celery is choking for example) ? Let me know what...
Hi, The [readme seems to suggest that the `celery_tasks_total` is a gauge](https://github.com/OvalMoney/celery-exporter/blame/master/README.md#L85) but it's implemented as a [Counter](https://github.com/OvalMoney/celery-exporter/blob/master/celery_exporter/metrics.py#L3). Is there any plan to "revert" this to a gauge showing the...
Adding bucket options for histograms. The code is not ideal ( Globals ), but I did not want to refactor it. After some discussions, maybe we could find a better...
in https://github.com/OvalMoney/celery-exporter/pull/43#discussion_r612808628 @MRoci wrote: > since this PR now targets `x86_64-unknown-linux-musl` for docker build i am not sure if `libgcc` is needed anymore
Similar to all these options: ```python DEFAULT_BROKER = os.environ.get('BROKER_URL', 'redis://redis:6379/0') DEFAULT_ADDR = os.environ.get('DEFAULT_ADDR', '0.0.0.0:8888') DEFAULT_MAX_TASKS_IN_MEMORY = int(os.environ.get('DEFAULT_MAX_TASKS_IN_MEMORY', '10000')) DEFAULT_QUEUE_LIST = os.environ.get('QUEUE_LIST', []) ``` Can we have an environment variable for...
I noticed that the latency monitoring seems to only account for the time between when a worker receives a task and when it starts the task. However, it would be...
