celery 在flask 中的用法_flask celery celery_broker_url

当在Flask应用中使用Celery时，可以使用Celery的定时任务功能来执行一些定时操作。首先，你需要在Flask应用的配置文件中配置Celery的定时任务参数。以下是一个示例配置：

# Flask应用配置
CELERY_BROKER_URL = 'redis://localhost:6379/0'  # Redis连接URL
CELERY_RESULT_BACKEND = 'redis://localhost:6379/0'  # Redis连接URL

# Celery定时任务配置
CELERYBEAT_SCHEDULE = {
    'task1': {
        'task': 'app.tasks.task1',  # 任务路径
        'schedule': crontab(minute='*/5'),  # 每5分钟执行一次
    },
    'task2': {
        'task': 'app.tasks.task2',  # 任务路径
        'schedule': crontab(hour=8, minute=0),  # 每天8:00执行一次
    },
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15

在上面的示例中，我们配置了两个定时任务：task1和task2。task1每5分钟执行一次，task2每天8:00执行一次。

接下来，在Flask应用的初始化文件中创建一个Celery实例，并将其配置和Flask应用的配置进行关联。以下是一个示例：

from flask import Flask
from celery import Celery

app = Flask(__name__)
app.config.from_object('config')

celery = Celery(app.name, broker=app.config['CELERY_BROKER_URL'])
celery.conf.update(app.config)
1
2
3
4
5
6
7
8

在上面的示例中，我们创建了一个名为celery的Celery实例，并将其配置和Flask应用的配置进行关联。

然后，可以编写Celery任务。以下是一个示例：

from app import celery

@celery.task
def task1():
    # 任务1的代码逻辑
    pass

@celery.task
def task2():
    # 任务2的代码逻辑
    pass
1
2
3
4
5
6
7
8
9
10
11

在上面的示例中，我们使用@celery.task装饰器将函数注册为Celery任务。

最后，需要在终端中启动Celery worker来处理任务。可以使用以下命令：

celery -A app.celery worker --loglevel=info
1

在上面的命令中，-A app.celery指定了Celery实例的位置，worker表示启动Celery worker，--loglevel=info表示设置日志级别为info。

通过这样的配置，就可以在Flask应用中使用Celery来进行异步处理和定时任务了。