Configure Celery To Write Logs To Papertrail

celery_app.py

import logging
import os

from celery import Celery
from celery.schedules import crontab
from celery.signals import after_setup_logger, after_setup_task_logger
from django.conf import settings

os.environ.setdefault("DJANGO_SETTINGS_MODULE", "config.settings.local")


def setup_loggers(logger, *args, **kwargs):
    # SysLogHandle, augmenting to Papertrail
    handler = logging.handlers.SysLogHandler(address=settings.PAPERTRAIL_ADDRESS, )
    default_formatter = 'CeleryWorkers: {asctime} - {name} - {levelname} - {message}'
    formatter = logging.Formatter(default_formatter, style="{")
    handler.setFormatter(formatter)
    logger.addHandler(handler)


if not settings.DEBUG:
    after_setup_logger.connect(setup_loggers)
    after_setup_task_logger.connect(setup_loggers)

app = Celery("my_project")

#...