现状: 原钉钉发送消息是同步程序,发送钉钉消息程序中有记录 Flask 程序运行日志,日志包含当前请求用户信息,和请求参数信息。
问题:Flask 调用 Celery,Celery 执行程序后发送钉钉消息,钉钉消息程序中记录日志。
概要代码如下
# __init__.py
def create_app():
....
return app
# mycelery.py
def make_celery(app):
celery = Celery(__name__, broker=celeryconfig.broker_url, backend=celeryconfig.result_backend)
celery.config_from_object(celeryconfig)
class ContextTask(celery.Task):
def __call__(self, *args, **kwargs):
with app.app_context():
return self.run(*args, **kwargs)
celery.Task = ContextTask
return celery
app = Flask(__name__)
celery_app = make_celery(app)
# celery_task.py
@celery_app.task(bind=True,ignore_result=True,max_retries=5)
def celery_stock_sync(self,**kwargs):
pass
# dd_utils.py
from record_log import run_log
def send_dd_msg():
res = dd_sdk.request()
run_log(res)
pass
# record_log.py
def run_log():
# 这里需要记录当前操作的用户信息,以及用户请求信息
user_id = g.get('user_id',None)
method= request.method
pass