FilesExpand file tree

 master

/

python_celery.py

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

21 lines (16 loc) · 475 Bytes

 master

/

python_celery.py

Copy path

Top

File metadata and controls

• Code
• Blame

21 lines (16 loc) · 475 Bytes

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

# _*_ coding: utf-8 _*_

"""

测试celery

运行：celery -A celery1:app worker -l INFO

"""

import time

from celery import Celery

broker = 'redis://152.136.149.221:9002/10' # 用redis做broker，中间件

backend = 'redis://152.136.149.221:9002/11' # 用redis做broken，用来保存结果

app = Celery('tasks',broker=broker,backend=backend)

@app.task

def add(x, y):

print(time.time(), x, y)

time.sleep(3)

print(time.time(), x, y, "--")

return x + y