from celery import Celery, platformsimport timeimport osfrom datetime import datetimeapp = Celery(‘proj‘,             broker=‘amqp://admin:admin@ip:5672‘,     //rabbitmq             backend=‘amqp://admin:admin@ip:5672‘,    //redis             //backend=‘redis://ip:10013/0‘,             include=[‘tasks‘]             )app.conf.update(    CELERYD_PREFETCH_MULTIPLIER=1,    CELERY_ACKS_LAT = True,)@app.taskdef fun_1(n):    return {"task_id": "0a14c9ac91de419880c4499a8f57418e",            "status": 0,            "desc": str(n) }@app.taskdef chk_total_callback(tasks_rets):    end_time = datetime.now()    print "end_time", end_time    return 0if __name__ == "__main__":    app.start()

from tasks import *                                                    from celery import group, chain                                        from datetime import datetime                                          import time                                                                                                                                                                                                          #job_group = group([fun_1.s(i) for i in range(30000)])                 beg_time = datetime.now()                                              for j in range(8000):    job_group = group([fun_1.s(i) for i in range(20)])                     chain(job_group, chk_total_callback.s())()                             #time.sleep(0.25)                                                                                                                         print "beg_time:", beg_time