|
|
@@ -50,8 +50,7 @@ class AccountCategoryAnalysis(CategoryRegression, AccountCategoryConst):
|
|
|
begin_dt = (run_date - timedelta(61)).strftime("%Y%m%d")
|
|
|
return begin_dt, end_dt
|
|
|
|
|
|
- async def prepare_raw_data(self, end_dt, begin_dt: str = "20250401"):
|
|
|
- begin_dt = "20250401"
|
|
|
+ async def prepare_raw_data(self, end_dt, begin_dt: str = "20250801"):
|
|
|
query = """
|
|
|
select dt, gh_id, account_name, title, similarity, view_count_rate, category,
|
|
|
read_avg, read_avg_rate, first_pub_interval, `index`
|
|
|
@@ -63,7 +62,6 @@ class AccountCategoryAnalysis(CategoryRegression, AccountCategoryConst):
|
|
|
and read_avg_rate between %s and %s
|
|
|
and view_count_rate > %s
|
|
|
and `index` < %s
|
|
|
- and account_name in ('生活慢时光', '美好时光阅读汇', '史趣探秘', '趣味生活漫谈', '趣味生活方式', '趣味生活漫时光')
|
|
|
;
|
|
|
"""
|
|
|
fetch_response = await self.pool.async_fetch(
|
luojunhui