save-daily-rank-log

.gitignore

@@ -64,3 +64,4 @@ target/
 
 .cursor
 
+.claude

app/domains/monitor_tasks/__init__.py

@@ -10,7 +10,7 @@ from .auto_reply_cards_monitor import AutoReplyCardsMonitor
 from .cooperate_accounts_monitor import CooperateAccountsMonitorTask
 from .fwh_group_publish_monitor import FwhGroupPublishMonitor
 from .ad_platform_accounts_monitor import AdPlatformAccountsMonitorTask
-
+from .rank_log_monitor import RankLogMonitor
 
 __all__ = [
     "check_kimi_balance",
@@ -25,4 +25,5 @@ __all__ = [
     "CooperateAccountsMonitorTask",
     "FwhGroupPublishMonitor",
     "AdPlatformAccountsMonitorTask",
+    "RankLogMonitor",
 ]

app/domains/monitor_tasks/rank_log_monitor/__init__.py

@@ -1 +1,3 @@
-from app.domains.monitor_tasks.rank_log_monitor.entrance import RankLogMonitor
+from .entrance import RankLogMonitor
+
+__all__ = ['RankLogMonitor']

app/jobs/task_handler.py

@@ -51,6 +51,7 @@ from app.domains.monitor_tasks import OutsideGzhArticlesCollector
 from app.domains.monitor_tasks import TaskProcessingMonitor
 from app.domains.monitor_tasks import LimitedAccountAnalysisTask
 from app.domains.monitor_tasks import AdPlatformAccountsMonitorTask
+from app.domains.monitor_tasks import RankLogMonitor
 
 from app.jobs.task_config import TaskStatus
 from app.jobs.task_utils import TaskValidationError
@@ -109,6 +110,11 @@ class TaskHandler:
         await self.log_client.log(contents=log_data)
 
     # ==================== 监控类任务 ====================
+    @register("rank_log_monitor")
+    async def _rank_log_monitor_handler(self) -> int:
+        """迁移排序日志"""
+        sub_task = RankLogMonitor(self.db_client, self.log_client)
+        return await sub_task.deal()
 
     @register("check_kimi_balance")
     async def _check_kimi_balance_handler(self) -> int: