def initialize_logstash(logger=None, loglevel=logging.DEBUG, **kwargs):
    handler = logstash.TCPLogstashHandler('localhost', 5959, tags=['worker'])
handler.setLevel(loglevel)
logger.addHandler(handler)
return logger
from celery.signals import after_setup_task_logger
after_setup_task_logger.connect(initialize_logstash)
from celery.signals import after_setup_logger
after_setup_logger.connect(initialize_logstash)
Как отправить сельдерей все журналы пользовательскому обработчику. в моем случае обработчик python-logstash