python - Django celery : Celery task does not create record in DB

Question

我想用 celery 任务创建数据库记录。但由于某种原因 object.save() 方法无法与 task.apply_async() (异步应用任务)一起使用。

在本地运行时，相同的记录(Ticker)会通过 celery 任务保存在数据库中:

get_all_tickers.apply()

但不是以异步方式保存:

get_all_tickers.apply_async()

在这两种情况下，INSERT 语句都在服务器日志中可见。

models.py

class Ticker(TimeStampedModel):
    ask = models.DecimalField(max_digits=18, decimal_places=8)
    bid = models.DecimalField(max_digits=18, decimal_places=8)
    pair = models.ForeignKey(Pair)

tasks.py

from celery import shared_task
...
@shared_task()
def get_all_tickers():
    pair = Pair.objects.last()
    ticker = Ticker(ask=Decimal(1.0), bid=Decimal(1.0), pair=pair)
    ticker.save()

Answer 1

Django 服务器(root)和 celery(celery_user)任务由不同的用户运行，因此，celery_user 没有写入权限数据库。那么 task.apply() 由 root 运行，并且可以 save() 记录和 task.apply_async() - 由 celery_user 提供，但不能。

此问题的短期解决方案是让 celery_user 成为数据库的所有者(使用 sqlite3 的开发环境):

chown celery_user:celery_user db.sqlite3

不过，向 celery_user 添加一个组会更合适(短期)。

或者长期 - 使用非特权用户运行所有内容 https://www.syncano.io/blog/configuring-running-django-celery-docker-containers-pt-1/

附注:我在使用 http://docs.celeryproject.org/en/latest/reference/celery.contrib.rdb.html 时遇到了一些问题(celery的调试工具)。每次收到任务时(即每 30 秒)，Telnet 就会断开连接。确保您正在使用专用于调试的任务。