我正试图使用celener创建一个异步任务,但没有成功。
我有一个发送电子邮件的任务:
@shared_task()
def send_email_example(email_id):
...
我使用delay()
方法称之为
class SomeModelExample:
...
def example(self):
...
send_email_example.delay(self.id)
在本地,我运行芹菜并可以使用它。然而,在我的服务器中,当我使用调用该函数的方法时,它需要30多秒,并且我收到状态代码502。
我希望我的芹菜设置是好的,因为我的周期性任务是有效的。
解决方案
我自己测试了一下,发现芹菜真的很好。问题出在我在服务器上的测试上。
在这个阶段,我会尝试:
- 使用不带括号的装饰器:@shared_task
- 将harakiri时间增加到>在服务器上等待60秒,看看是任务问题还是服务器问题