请教 Flask 离线程序中如何利用上下文传递 g 和 request 参数

[luxiaoer]

现状： 原钉钉发送消息是同步程序，发送钉钉消息程序中有记录 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

[luxiaoer]

@no1xsyzy
好的，谢谢

[nthhdy]

传 g 和 request 不合理，同意 @echowuhao 的方法

[Cookieeeeee]

把具体的信息取出来 celery 里头上下文和 flask 里头不一样 传对象取不到值

[Cookieeeeee]

或者序列化下传进去解耦

[goxy]

需要理解一下 context 的概念

Celery 和 Flask 都是独立设计的，你可以理解为两个职业不同的人在一起协同工作，A 要分配任务给 B，是需要通过发一份邮件之类的东西给 B，而不是把 A B 缝起来让他们成为连体婴儿。g 和 request 都是设计在 flask 内部的，对于 celery 是透明的，而开发上要做的是设计这样一份 邮件

[cz5424]

启动任务把参数传进去就好了，不要用全局，他们都是互相独立的进程

[cz5424]

不要觉得 g 和上下文变量很酷，声明多了你都不知道声明了多少个全局变量。

[luxiaoer]

感谢以上的提醒，已经用了 3 楼的思路重写中。
重写一半又准备重写了，准备把日志记录功能拆解到 Celery 中做异步日志记录😂
每次都不想重写，然鹅一次次重写
@Cookieeeeee
@goxy
@cz5424