使用allow_join_result。请参见下面的代码段。
@app.task(ignore_result=True)def catpure_res(task_id): task_obj = AsyncResult(task_id) with allow_join_result(): task_obj.get(on_message=on_msg)
注意：如其他答案中所述，它可能导致性能问题甚至死锁，但是如果您的任务写得好并且没有引起意外的错误，则它应该像魅力一样工作。
使用allow_join_result。请参见下面的代码段。
@app.task(ignore_result=True)def catpure_res(task_id): task_obj = AsyncResult(task_id) with allow_join_result(): task_obj.get(on_message=on_msg)
注意：如其他答案中所述，它可能导致性能问题甚至死锁，但是如果您的任务写得好并且没有引起意外的错误，则它应该像魅力一样工作。
名师互学网 版权所有 (c)2021-2022 ICP备案号：晋ICP备2021003244-6号
