41 lines
1.0 KiB
Python
41 lines
1.0 KiB
Python
from django.conf import settings
|
|
from django.db.models.signals import post_save, post_delete
|
|
from django_statsd.clients import statsd
|
|
|
|
from .celery import register_celery_events
|
|
|
|
|
|
if getattr(settings, 'STATSD_CELERY_SIGNALS', False):
|
|
register_celery_events()
|
|
|
|
|
|
def model_save(sender, **kwargs):
|
|
"""
|
|
Handle ``save`` events of all Django models.
|
|
"""
|
|
instance = kwargs.get('instance')
|
|
|
|
# Increase statsd counter.
|
|
statsd.incr('models.%s.%s.%s' % (
|
|
instance._meta.app_label,
|
|
instance._meta.object_name,
|
|
'create' if kwargs.get('created', False) else 'update',
|
|
))
|
|
|
|
|
|
def model_delete(sender, **kwargs):
|
|
"""
|
|
Handle ``delete`` events of all Django models.
|
|
"""
|
|
instance = kwargs.get('instance')
|
|
|
|
# Increase statsd counter.
|
|
statsd.incr('models.%s.%s.delete' % (
|
|
instance._meta.app_label,
|
|
instance._meta.object_name,
|
|
))
|
|
|
|
if getattr(settings, 'STATSD_MODEL_SIGNALS', True):
|
|
post_save.connect(model_save)
|
|
post_delete.connect(model_delete)
|