feat: 文章收益排行榜加入唯一索引

jobs/fetch_article_earning_ranking_records.py

@@ -7,6 +7,7 @@
 from jkit.ranking.article_earning import ArticleEarningRanking, RecordField
 from prefect import flow, get_run_logger
 from prefect.states import Completed, State
+from pymongo import ASCENDING, IndexModel
 
 from utils.config_generators import generate_deployment_config, generate_flow_config
 from utils.db import DB
@@ -100,6 +101,10 @@ async def process_item(
     )
 )
 async def flow_func() -> State:
+    await COLLECTION.create_indexes(
+        [IndexModel([("date", ASCENDING), ("ranking", ASCENDING)], unique=True)]
+    )
+
     target_date = datetime.now().date() - timedelta(days=1)
 
     data: List[ArticleEarningRankingRecordDocument] = []