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

Question

我正在使用 celery 来安排任务。到目前为止一切都很好，包括托管在 AWS 上。但是，我决定使用 django-tenant 将单一应用程序转换为 Multi-Tenancy 。这样，我就可以完美地创建子域。

./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 实现并注入(inject) db_schema 并使用它

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