请教 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

[coolair]

with app.app_context():
# ...

[luxiaoer]

@coolair
求详细知道
是否在 run_log 函数中 with app.app_context()
app 有是如何导入的
如果是 app 是如何导入，如果 from app import create_app 会提示循环导入
如果从 Flask(__name__) g 为 None request 会提示 Working outside of request context.

另外我在 celery_task 中也尝试 with app.app_context()，g 也是 None

[echowuhao]

你应该换方式 把需要得信息在 context 里面提取出来 传给 celery 而不是在 celery 中获取

[luxiaoer]

@echowuhao
可以是可以，但是这种方式不够解藕
如果后续需要添加新的字段，就需要整个调整。
关键是，原来的 run_log 就需要重写，就不能用 g 和 request 。相关的调用程序也需要重写吧

[rimutuyuan]

copy.deepcopy 可以实现么

[echowuhao]

@luxiaoer 代码要尽量少用 global 的东西 refactor 你的代码 object 进入 celery 都要序列化一个来回 费时费力

[luxiaoer]

@echowuhao
我们外部供应商给我们做外包，动不动就重构
我自己写应用，有时候也动不动就重构
但是自己挺反感重构的，怕缺陷。
个人 觉得用 g 变量 和上下文是件很酷的事情 😂
不过还是谢谢，提供一个思路

[echowuhao]

@luxiaoer 你们单元测试咋写的。应该把每个函数的输入最小化，尽量减少 global，否则我不知道你们咋做测试的。

[no1xsyzy]

因为 flask 是用的 thread local
g 和 request 信息限定在当前 thread 内有效。

[luxiaoer]

@rimutuyuan
copy 还是 参数传递 方式，就还是后续调整会觉得麻烦。
我朝着这个方向也思考思考
大家 都不用 g 和上下文么，不酷么😂

[luxiaoer]

@no1xsyzy
但是可以用上下文不是么。

[echowuhao]

celery 你可以理解为对当前程序任务的外包。

外包的时候，你们会把现在公司的所有数据都送给他们，让他们方便么。只给最少能完成任务的信息。

这个在原理上没有任何问题。外包的人说，把你们的数据都给我，多方便，你干么。

[luxiaoer]

@echowuhao
有道理，那我暂且去重构了
仍然期待上下文的解决方案

[kaneg]

flask 上下文只对当前线程有效，celery 是在新线程中异步执行，是无法获取当时 de 信息。
你要做的时触发 job 时把当前需要传递的信息传给 celery 。

[luxiaoer]

@kaneg
感谢解惑

[no1xsyzy]

@luxiaoer app.app_context() 是建立了一个 dummy 上下文，里面就是些假数据。

[SjwNo1]

flask 线程隔离的
可以 app._get_current_object() 传给 task

[qdzzyb]

flask 在一个进程里，celery 的 worker 在另外一个进程里
celery worker 启动以后的 app 对象跟 flask 里的 app 对象不是同一个东西。

3 楼已经的做法已经是最好的办法了, 后续添加新字段 worker 的处理函数还得处理

实在想传 g 大概得用 pickle

[luxiaoer]

@SjwNo1
尝试过，没成功

[luxiaoer]

@qdzzyb
目前在这个方向努力