pdf_title_image/celery_tasks/__init__.py

# -*- coding: utf-8 -*-
# @Author: privacy
# @Date:   2024-08-27 11:19:15
# @Last Modified by:   privacy
# @Last Modified time: 2024-09-29 13:32:08
from celery import Celery

celery_app = Celery(
    'tasks',
    broker='redis://:test@127.0.0.1:6379/0',
    # backend='redis://:test@127.0.0.1:6379/1',
    backend='db+sqlite:///celeryresults.sqlite3',
    include=[  # 执行任务库，代表所能执行的所有任务，即通过@celery_app.task修饰的所有函数
        'celery_tasks.commonprocess',
        # 'celery_tasks.business_part',
        # 'celery_tasks.technical_part'
    ]
)

celery_app.conf.update(
    broker_connection_retry_on_startup=True
)

# celery_app.config_from_object('celeryconfig')

if __name__ == '__main__':
    celery_app.start()