Celery 响应显示在 Flask 应用程序中

Question

Views.py

class UserCreate(Resource):
        def post(self):
            # try:
             celery=create_user_employee.delay(auth_header, form_data, employee_id, employee_response)
                    # from celery import current_task
                    if "exc" in celery.get:
                        # print(celery)
                        return deliver_response(False, 'Celery task failed'), 400                    
                    return deliver_response(True, message="User Creation in Progress", status=200, data=data), 200

Task.py

@celery.task(name='accounts.tasks.create_user_employee')
def create_user_employee(auth_header, form_data, employee_id, employee_response):
    try:
        # add_employee(form_data, employee_id, eid)
        if "streetLane" in form_data:
            user_id=form_data.get("personalEmail","")
            employee_address=address_post__(form_data, auth_header, user_id)
        return deliver_response(True,message="success",status=200),200
    except Exception as e:
            return deliver_response(False, str(e), status=500), 500
    

注意：我无法从task.py返回对flask应用程序的响应，这里的目标是，如果task.py有任何错误响应，我需要中断views.py函数但结果是无法在views.py中导入或打印任何帮助都会很棒。 ...................................................... ...................................................... ...................................................... ................................

Answer 1

由于 celery 进程是一个异步进程，因此您不会立即得到 celery 作业的响应。
所以这段代码

celery=create_user_employee.delay(auth_header, form_data, employee_id, employee_response)

不会给你任务的结果。因此 celery 变量不会提供任务完成的任何有意义的信息。也不要使用celery作为变量名。
因此，要获取 celery 任务的结果，

from celery import result
res = result.AsyncResult(job_id)

res 变量具有 res.status 和 res.result 来获取任务的状态和结果 job_id 任务。您可以在调用 celery 任务时设置自己的作业 id。
何时获取这些结果取决于您。要么编写一个定期查看作业状态的递归函数，要么在需要结果时尝试查看作业状态。

Answer 2

我希望在 if "exc" in celery.get: ... 的地方抛出一个错误 TypeError: argument of type 'function' is not iterable< /代码>。

您是否尝试稍微更改该行并在 celery.get(): 中有 if "exc": （注意括号）？

另外，将delay()的结果命名为“celery”是一种误导——任何阅读你的代码的人都可能认为这是Celery类的一个实例，但事实并非如此。这是 AsyncResult 类型的实例。 获取() 只是其方法之一。