pip install celery
python
from celery import Celery
app = Celery('myapp', broker='redis://localhost:6379/0')
@app.task
def fibonacci(n):
if n <= 0:
return []
elif n == 1:
return [0]
elif n == 2:
return [0, 1]
else:
fib = [0, 1]
for i in range(2, n):
fib.append(fib[-1] + fib[-2])
return fib
celery -A celery_app:app worker --loglevel=info
python
from celery_app import fibonacci
result = fibonacci.delay(10)
print(result.get())
python
app.conf.update(
result_backend='redis://localhost:6379/1',
result_backend_transport_options={'visibility_timeout': 3600},
task_time_limit=300
)
