mirror of
https://github.com/fastapi-practices/fastapi_best_architecture.git
synced 2026-03-13 09:31:31 +08:00
5e438c685d
* define the basic architecture * Update script and deployment file locations * Update the route registration * Fix CI download dependencies * Updated ruff to 0.3.3 * Update app subdirectory naming * Update the model import * fix pre-commit pdm lock * Update the service directory naming * Add CRUD method documents * Fix the issue of circular import * Update the README document * Update the SQL statement for create tables * Update docker scripts and documentation * Fix docker scripts * Update the backend README.md * Add the security folder and move the redis client * Update the configuration item * Fix environment configuration reads * Update the default configuration * Updated README description * Updated the user registration API * Fix test cases * Update the celery configuration * Update and fix celery configuration * Updated the celery structure * Update celery tasks and api * Add celery flower * Update the import style * Update contributors
60 lines
1.8 KiB
Python
60 lines
1.8 KiB
Python
#!/usr/bin/env python3
|
|
# -*- coding: utf-8 -*-
|
|
from celery import Celery
|
|
|
|
from backend.app.task.conf import task_settings
|
|
from backend.core.conf import settings
|
|
|
|
__all__ = ['celery_app']
|
|
|
|
|
|
def init_celery() -> Celery:
|
|
"""创建 celery 应用"""
|
|
|
|
app = Celery('fba_celery')
|
|
|
|
# Celery Config
|
|
# https://docs.celeryq.dev/en/stable/userguide/configuration.html
|
|
_redis_broker = (
|
|
f'redis://:{settings.REDIS_PASSWORD}@{settings.REDIS_HOST}:'
|
|
f'{settings.REDIS_PORT}/{task_settings.CELERY_BROKER_REDIS_DATABASE}'
|
|
)
|
|
_amqp_broker = (
|
|
f'amqp://{task_settings.RABBITMQ_USERNAME}:{task_settings.RABBITMQ_PASSWORD}@'
|
|
f'{task_settings.RABBITMQ_HOST}:{task_settings.RABBITMQ_PORT}'
|
|
)
|
|
_result_backend = (
|
|
f'redis://:{settings.REDIS_PASSWORD}@{settings.REDIS_HOST}:'
|
|
f'{settings.REDIS_PORT}/{task_settings.CELERY_BACKEND_REDIS_DATABASE}'
|
|
)
|
|
_result_backend_transport_options = {
|
|
'global_keyprefix': f'{task_settings.CELERY_BACKEND_REDIS_PREFIX}_',
|
|
'retry_policy': {
|
|
'timeout': task_settings.CELERY_BACKEND_REDIS_TIMEOUT,
|
|
},
|
|
}
|
|
|
|
# Celery Schedule Tasks
|
|
# https://docs.celeryq.dev/en/stable/userguide/periodic-tasks.html
|
|
_beat_schedule = task_settings.CELERY_SCHEDULE
|
|
|
|
# Update celery settings
|
|
app.conf.update(
|
|
broker_url=_redis_broker if task_settings.CELERY_BROKER == 'redis' else _amqp_broker,
|
|
result_backend=_result_backend,
|
|
result_backend_transport_options=_result_backend_transport_options,
|
|
timezone=settings.DATETIME_TIMEZONE,
|
|
enable_utc=False,
|
|
task_track_started=True,
|
|
beat_schedule=_beat_schedule,
|
|
)
|
|
|
|
# Load task modules
|
|
app.autodiscover_tasks(task_settings.CELERY_TASKS_PACKAGES)
|
|
|
|
return app
|
|
|
|
|
|
# 创建 celery 实例
|
|
celery_app = init_celery()
|