是否可以将django-celery-beat与django-tenant一起使用?

Question

我正在使用芹菜来调度任务。到目前为止，一切都很好，包括在AWS上托管。但是，我决定使用 django-tenant 将我的单个应用程序转换为多租户。这样，我就可以完美地创建子域。

./manage.py create_tenant

但是，在运行命令时celery -A myproject worker -B，尽管没有向我显示任何错误，但在我看来，他无法为创建的模式运行(仅创建一个模式进行测试(。

我尝试使用python manage.py tenant_command celery worker -B --loglevel = info --schema = myschema指定架构 但我收到以下错误：

raise CommandError ("Unknown command:% r"% argv [2])
django.core.management.base.CommandError: Unknown command: 'celery'

如果有人能帮助我，我真的很感激！ 如果可以为特定架构运行命令，是否也可以对创建的所有架构全局运行？谢谢！

Answer 1

你应该扩展芹菜任务实现并注入db_schema并改用它

但也可以不重新发明轮子并使用 https://github.com/maciej-gol/tenant-schemas-celery