是否可以在django-tenant中使用django-celery-beat？

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

您应该扩展celery Task实现并注入db_schema并使用它代替