【发布时间】:2020-04-05 23:10:11
【问题描述】:
我想通过 Celery 监听现有的 SQS 队列。 我已经通过 celery 发布到队列,然后通过绑定到该队列的工作人员和任务从该队列消费。 但是,如果发布者是非芹菜 Django 应用程序,我无法弄清楚如何从 SQS 队列中消费。互联网上没有关于此的此类信息,或者至少我无法找到它。有人可以指导我做一些文档吗?
【问题讨论】:
标签: python django celery amazon-sqs
我想通过 Celery 监听现有的 SQS 队列。 我已经通过 celery 发布到队列,然后通过绑定到该队列的工作人员和任务从该队列消费。 但是,如果发布者是非芹菜 Django 应用程序,我无法弄清楚如何从 SQS 队列中消费。互联网上没有关于此的此类信息,或者至少我无法找到它。有人可以指导我做一些文档吗?
【问题讨论】:
标签: python django celery amazon-sqs
如果我正确理解了您想要做什么,我有一个坏消息要告诉您 - 这是不可能的。 Celery 只能消费自己的消息。如果您的 Django 应用程序需要使用 SQS 作为代理向 Celery 集群发送一些任务,它需要实例化一个 Celery 应用程序对象,并使用它来发送任务。
【讨论】: