tasks.py 文件源码

def test(tid, n):
    for i in range(n):
        x = random.normal(0, 0.1, 2000)
        y = fft(x)
    result = dict()
    result['x'] = random.random()
    result['y'] = random.randint(100)
    return result


# @task_success.connect(sender='celeryapp.tasks.fft_random')