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

Question

有没有办法将代理/队列中的消息内容映射到某个任务？我正在将 SQS 和 celery 用于工作人员架构，并且我的工作人员具有 python 任务/功能。我要做的是根据消息的内容调用一个任务。例如，如果我的员工定义了以下任务：

@celery.task
def add(message):
    pass

@celery.task
def subtract(message):
    pass

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

Answer 1

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