【问题标题】:How to listen to already existing SQS queue with Celery and Django?如何使用 Celery 和 Django 监听现有的 SQS 队列?
【发布时间】:2020-04-05 23:10:11
【问题描述】:

我想通过 Celery 监听现有的 SQS 队列。 我已经通过 celery 发布到队列,然后通过绑定到该队列的工作人员和任务从该队列消费。 但是,如果发布者是非芹菜 Django 应用程序,我无法弄清楚如何从 SQS 队列中消费。互联网上没有关于此的此类信息,或者至少我无法找到它。有人可以指导我做一些文档吗?

【问题讨论】:

    标签: python django celery amazon-sqs


    【解决方案1】:

    如果我正确理解了您想要做什么,我有一个坏消息要告诉您 - 这是不可能的。 Celery 只能消费自己的消息。如果您的 Django 应用程序需要使用 SQS 作为代理向 Celery 集群发送一些任务,它需要实例化一个 Celery 应用程序对象,并使用它来发送任务。

    【讨论】:

    • 感谢@DejanLekic 的回答。这时候我更热衷于监听其他一些应用发布的来自 SQS 的消息。
    猜你喜欢
    • 2021-10-15
    • 2016-10-07
    • 2021-12-18
    • 2018-11-29
    • 2016-10-17
    • 1970-01-01
    • 1970-01-01
    • 2020-02-08
    • 1970-01-01
    相关资源
    最近更新 更多