在芹菜Python中，一个任务的输出并行处理任务

Question

我已创建任务

@app.task 
def mainTask(msg,nc): 
    decryptFunction.decryptFunc(msg) 
    if len(decryptFunction.messageJson): 

我异步接收数据。

def on_message(client, userdata, msg): 
    result = mainTask.delay(msg.payload.decode("utf-8"),1) 

我需要使用输出decryptFunction.messageJson在5个任务，并同时运行

Answer 1

我从你的需求理解是什么，我会建议而不是使mainTask，因为异步可以调用其他5个任务作为celery任务，从mainTask即

def mainTask(msg, nc): 
    decryptFunction.decryptFunc(msg) 
    if len(decryptFunction.messageJson): 
     response1 = task1.delay(decryptFunction.messageJson) 
     response2 = task2.delay(decryptFunction.messageJson) 
     response3 = task3.delay(decryptFunction.messageJson) 
     response4 = task4.delay(decryptFunction.messageJson) 
     response5 = task5.delay(decryptFunction.messageJson) 

和你on_message功能：

def on_message(client, userdata, msg): 
    result = mainTask(msg.payload.decode("utf-8"),1) 

但是这是假设你的其他5个任务是互斥的，并且对其中一个的响应不影响另一个任务，因为如果他们不是，你不能使他们成为异步任务。

但是，如果你的mainTask是耗时的，你可以使用它作为Celery任务。