tonywangcn

<?php if (!defined('BASEPATH')) exit('No direct script access allowed');

/**
 * @ignore
 */
class OAuthException extends Exception {
	// pass
}

class Oauth2_lib {

tonywangcn

"""Genetic Algorithmn Implementation
"""
#引入随机函数
import random

#定义基因遗传算法顶层接口
class GeneticAlgorithm(object):

    # 定义算法初始化
    def __init__(self, genetics):

tonywangcn

from __future__ import absolute_import
from celery import Celery
app = Celery('test_celery',broker='amqp://admin:[email protected]:5672',backend='rpc://',include=['test_celery.tasks'])

tonywangcn

from .tasks import longtime_add
import time
if __name__ == '__main__':
    for _ in xrange(10):
        result = longtime_add.delay(1,2)
        print 'Task finished?',result.ready()
        print 'Task result:',result.result
        time.sleep(1)
        print 'Task finished"',result.ready()
        print 'Task result:',result.result

tonywangcn

from __future__ import absolute_import
from test_celery.celery import app
import time
@app.task
def longtime_add(x,y):
    print 'long time task begins'
    time.sleep(5)
    print 'long time task finished'
    return x + y

tonywangcn

from __future__ import absolute_import
from test_celery.celery import app
import time
@app.task
def longtime_add(x,y):
    print 'long time task begins'
    time.sleep(5)
    print 'long time task finished'
    return x + y

tonywangcn

version: '2'
services:
    rabbit:
        hostname: rabbit
        image: rabbitmq:latest
        environment:
            - RABBITMQ_DEFAULT_USER=admin
            - RABBITMQ_DEFAULT_PASS=mypass
        ports:
            - "5672:5672"

tonywangcn

FROM python:2.7
ADD requirements.txt /app/requirements.txt
ADD ./test_celery/ /app/
WORKDIR /app/
RUN pip install -r requirements.txt
ENTRYPOINT celery -A test_celery worker --loglevel=info

tonywangcn

celery==4.0.2

tonywangcn

docker-cluster-with-celery-and-rabbitmq
  -- test_celery
    -- __init__.py
    -- celery.py
    -- tasks.py
    -- run_tasks.py
  -- docker-compose.yml
  -- dockerfile
  -- requirements.txt