有没有办法将代理/队列中的消息内容映射到某个任务?我使用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-18 16:45:36
Celery不使用任意的SQS消息。您必须使用正确配置的Celery实例和apply_async()、delay()或send_task()方法将有效的Celery消息发送到SQS队列。
https://stackoverflow.com/questions/63945918
复制相似问题