问题描述
我们正在尝试将 Celery 用于我们的多租户应用程序 - 作为示例的应用程序为每个租户发送电子邮件。
Producer 添加要发送到队列的电子邮件。我们有多个生产者根据租户不断添加到队列中。
在工作人员方面，我们需要一种方法来根据租户对所有这些电子邮件进行分组，以便我们可以将它们集中处理。
我们最初的想法是将所有电子邮件存储到 redis，同时向 celery 添加一个任务来为每个租户执行。然后 worker 从 redis 中获取所有任务，组装并批量发送。
但它正在重新发明轮子，我们认为 Celery 也可以使这成为可能。
- 是否可以为每个任务赋予一个密钥，而 Celery 可以根据每个密钥只能执行一次的密钥赋予所有这些任务？
解决方法
暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！
如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@）