时间戳

首页 > 解决方案 > 在 Python 中使用 celery 调用类的实例方法

django - 在 Python 中使用 celery 调用类的实例方法

问题描述

在旧版本的Celery中，可以根据http://docs.celeryproject.org/en/3.1/reference/celery.contrib.methods.html将实例方法转换为 celery 任务，如下面的示例

from celery.contrib.methods import task
class X(object):
    @task()
    def add(self, x, y):
        return x + y

我使用的是 Celery 4.1，它默认没有这样的功能。我怎样才能以某种简单的方式自己实现这个功能？

让我举例说明我的要求。 

from abc import ABC, abstractmethod

AbstractService(ABC):

    def __init__(self, client_id, x, y):
        self.client_id = client_id
        self.x = x
        self.y = y

    @abstractmethod
    def preProcess(self):
        '''Some common pre processing will execute here'''

    @abstractmethod
    def process(self):
        '''Some common processing will execute here'''

    @abstractmethod
    def postProcess(self):
        '''Some common post processing will execute here'''

Client1Service(AbstractService):

    def __init__(self, x, y):
        super(__class__, self).__init__('client1_id', x, y)

    # I want to run this using celery
    def preProcess(self):
        super().preProcess()

    # I want to run this using celery
    def process(self):
        data = super().process()
        # apply client1 rules to data
        self.apply_rules(data)
        print('task done')

    # I want to run this using celery
    def postProcess(self):
        super().postProcess()  

    def appy_rules(self, data):
        '''Client 1 rules to apply'''
        # some logic

我想在django项目中使用 celery运行preProcess和process类。postProcessClient1Service

如果我得不到任何解决方案，那么我将不得不在一些外部 celery 任务中运行 preProcess、process 和 postProcess 的逻辑，这会有点混乱。
建议我为此要求进行一些设计。

标签： djangopython-3.xceleryabstract-classdjango-celery

解决方案

尝试使用：

from celery import shared_task
@shared_task(bind=True)
def yourfunction():
    dosth()

这里有一个很好的教程：http ://docs.celeryproject.org/en/latest/django/first-steps-with-django.html

推荐阅读