在Celery中使用SQLite作为消息代理

基于chatgpt生成

要在Celery中使用SQLite作为消息代理，需要在Celery配置文件中进行以下更改：

1. 安装sqlite3驱动程序

pip install pysqlite3

2. 配置Celery

# 导入pysqlite3驱动程序
import pysqlite3

# 使用SQLite作为消息代理
BROKER_URL = 'sqla+sqlite:///celerydb.sqlite3'

# 配置SQLite数据库连接
CELERY_RESULT_BACKEND = 'db+sqlite:///celeryresults.sqlite3'
CELERY_RESULT_DBURI = 'sqlite:///celeryresults.sqlite3'

# 配置SQLite连接池
CELERYD_POOL_RESTARTS = True
CELERYD_MAX_TASKS_PER_CHILD = 1000
CELERYD_CONCURRENCY = 4

# 配置任务序列化方式
CELERY_TASK_SERIALIZER = 'json'
CELERY_ACCEPT_CONTENT = ['json']

# 配置结果序列化方式
CELERY_RESULT_SERIALIZER = 'json'

# 配置时区
CELERY_TIMEZONE = 'Asia/Shanghai'

# 配置导入的任务模块
CELERY_IMPORTS = (
    'tasks',
)

# 配置beat定时器
CELERYBEAT_SCHEDULE = {
    'task-name': {
        'task': 'tasks.task_name',
        'schedule': crontab(minute='*/10'),
    },
}

3. 创建数据库表格

celery -A proj worker --loglevel=info

from celery import Celery
from celery.backends import database as celery_database

app = Celery('proj')
app.config_from_object('proj.celeryconfig')

with app.connection() as conn:
    celery_database.create_all_tables(app=app, connection=conn)

以上步骤完成后，就可以在Celery中使用SQLite作为消息代理了。