问将队列/代理内容映射到任务
EN

Stack Overflow用户

提问于 2020-09-18 04:41:11

回答 1查看 39关注 0票数 0

有没有办法将代理/队列中的消息内容映射到某个任务？我使用SQS和芹菜作为worker架构，我的worker有python任务/函数。我想做的是根据消息的内容调用一个任务。例如，如果我的员工定义了以下任务：

@celery.task
def add(message):
    pass

@celery.task
def subtract(message):
    pass

如果SQS队列中的消息具有{"operation": "add“}，则应调用”add“任务；如果消息具有{"operation": "subtract "}，则应调用”subtract task“

发布于 2020-09-19 00:45:36

Celery不使用任意的SQS消息。您必须使用正确配置的Celery实例和apply_async()、delay()或send_task()方法将有效的Celery消息发送到SQS队列。

票数 0

页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持

原文链接：

https://stackoverflow.com/questions/63945918

复制

相似问题

问将队列/代理内容映射到任务EN