From 4d3c72a6969b1102e773ec26069002a00c7fd92a Mon Sep 17 00:00:00 2001
From: liangtianyu <124244236@qq.com>
Date: Sat, 13 Dec 2025 09:22:19 +0800
Subject: [PATCH 1/2] =?UTF-8?q?=E6=B3=A8=E9=87=8A=E7=9B=AE=E5=89=8D?=
 =?UTF-8?q?=E4=B8=8D=E4=BD=BF=E7=94=A8=E7=9A=84=E4=BB=BB=E5=8A=A1?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 app/celery_app.py | 32 ++++++++++++++++++++------------
 1 file changed, 20 insertions(+), 12 deletions(-)

diff --git a/app/celery_app.py b/app/celery_app.py
index 9b23ca1..18b849e 100644
--- a/app/celery_app.py
+++ b/app/celery_app.py
@@ -1,10 +1,16 @@
 """
 Celery应用配置
 """
+
 from celery import Celery
 from celery.schedules import crontab
 from app.config import settings
-from app.logger import get_celery_logger, get_celery_beat_logger, get_celery_worker_logger, LoggerManager
+from app.logger import (
+    get_celery_logger,
+    get_celery_beat_logger,
+    get_celery_worker_logger,
+    LoggerManager,
+)
 
 # 确保日志系统初始化
 LoggerManager.setup_logging()
@@ -17,7 +23,7 @@ celery_app = Celery(
     "ai_talk_callback",
     broker=settings.celery_broker_url,
     backend=settings.celery_result_backend,
-    include=['app.celery_tasks']
+    include=["app.celery_tasks"],
 )
 
 # Celery配置
@@ -32,21 +38,21 @@ celery_app.conf.update(
     task_soft_time_limit=25 * 60,  # 25分钟软超时
     worker_prefetch_multiplier=1,
     worker_max_tasks_per_child=1000,
-    
     # Worker日志配置
-    worker_log_format='[%(asctime)s: %(levelname)s/%(processName)s] %(message)s',
-    worker_task_log_format='[%(asctime)s: %(levelname)s/%(processName)s][%(task_name)s(%(task_id)s)] %(message)s',
-    
+    worker_log_format="[%(asctime)s: %(levelname)s/%(processName)s] %(message)s",
+    worker_task_log_format="[%(asctime)s: %(levelname)s/%(processName)s][%(task_name)s(%(task_id)s)] %(message)s",
     # Beat 调度配置
     # crontab(hour=9, minute=0)  # 每天上午9点执行
     beat_schedule={
-        'push-data-to-dtc-every-minute': {
+        """
+         'push-data-to-dtc-every-minute': {
             'task': 'push_data_to_dtc',
             'schedule': 120.0,  # 每120秒执行一次（2分钟）
         },
-        'daily-morning-task': {
-            'task': 'call_api',
-            'schedule': crontab(hour=9, minute=0),  # 每天上午9点执行
+        """
+        "daily-morning-task": {
+            "task": "call_api",
+            "schedule": crontab(hour=9, minute=0),  # 每天上午9点执行
         },
     },
 )
@@ -63,5 +69,7 @@ worker_logger.info("⚙️ Worker 配置参数:")
 worker_logger.info(f"  - 任务超时: {celery_app.conf.task_time_limit}秒")
 worker_logger.info(f"  - 软超时: {celery_app.conf.task_soft_time_limit}秒")
 worker_logger.info(f"  - 预取倍数: {celery_app.conf.worker_prefetch_multiplier}")
-worker_logger.info(f"  - 每个子进程最大任务数: {celery_app.conf.worker_max_tasks_per_child}")
-worker_logger.info(f"  - 包含模块: {celery_app.conf.include}")
\ No newline at end of file
+worker_logger.info(
+    f"  - 每个子进程最大任务数: {celery_app.conf.worker_max_tasks_per_child}"
+)
+worker_logger.info(f"  - 包含模块: {celery_app.conf.include}")

From 6e9dc7f3ca6c9bff25bb5ab61fc4401ec32e309f Mon Sep 17 00:00:00 2001
From: liangtianyu <124244236@qq.com>
Date: Sat, 13 Dec 2025 09:27:44 +0800
Subject: [PATCH 2/2] =?UTF-8?q?=E5=88=A0=E9=99=A4=E6=97=A0=E6=95=88?=
 =?UTF-8?q?=E4=BB=BB=E5=8A=A1?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 app/celery_app.py | 6 ------
 1 file changed, 6 deletions(-)

diff --git a/app/celery_app.py b/app/celery_app.py
index 18b849e..e9daea4 100644
--- a/app/celery_app.py
+++ b/app/celery_app.py
@@ -44,12 +44,6 @@ celery_app.conf.update(
     # Beat 调度配置
     # crontab(hour=9, minute=0)  # 每天上午9点执行
     beat_schedule={
-        """
-         'push-data-to-dtc-every-minute': {
-            'task': 'push_data_to_dtc',
-            'schedule': 120.0,  # 每120秒执行一次（2分钟）
-        },
-        """
         "daily-morning-task": {
             "task": "call_api",
             "schedule": crontab(hour=9, minute=0),  # 每天上午9点执行