celery_init.py 文件源码

def task_before_sent_handler(sender=None, headers=None, body=None, **kwargs):
    # information about task are located in headers for task messages
    # using the task protocol version 2.
    mongoengine.connect(**celery_config.mongoengine_SETTINGS)
    task_name = sender
    args = headers.get('argsrepr')
    task_id = headers.get('id')
    task_monitor_ob = task_monitor()
    task_monitor_ob.task_id = task_id
    task_monitor_ob.task_name = task_name
    task_monitor_ob.before_sent_args = args
    now = datetime.now(tz = pytz.timezone('Asia/Shanghai'))
    task_monitor_ob.create_time = now
    task_monitor_ob.update_time = now
    task_monitor_ob.celery_stask_status = 0
    task_monitor_ob.save()