调试

data_channel/kuaishou.py

@@ -130,9 +130,9 @@ class KS:
                     AliyunLogger.logging(channel_id, name, url_id, video_id, "扫描到一条视频", "2001", log_data)
                     Common.logger("ks").info(
                         f"扫描：{task_mark},用户主页id:{url_id},视频id{video_id} ,播放数:{view_count} ,分享数:{share_count},时长:{duration} ")
-                    if status:
-                        AliyunLogger.logging(channel_id, name, url_id, video_id, "该视频已改造过", "2002", log_data)
-                        continue
+                    # if status:
+                    #     AliyunLogger.logging(channel_id, name, url_id, video_id, "该视频已改造过", "2002", log_data)
+                    #     continue
                     special = float(0.001)
                     if float(video_percent) < special:
                         AliyunLogger.logging(channel_id, name, url_id, video_id, "不符合规则:分享/浏览小于0.001", "2003", log_data)

video_count_notification.py

@@ -23,16 +23,16 @@ def bot_carry_data():
         xx_count = sqlCollect.get_name_count("信欣")
         dd_count = sqlCollect.get_name_count("单点视频")
         text = (
-            f"**抖音品类账号**: {int(dy_count[0][0])}**条**\n"
-            f"**抖音搜索**: {int(dy_sou_count[0][0])}**条**\n"
-            f"**视频号品类账号**: {int(sph_count[0][0])}**条**\n"
-            f"**视频号推荐流**: {int(sph_feed_count[0][0])}**条**\n"
-            f"**视频号搜索**: {int(sph_sou_count[0][0])}**条**\n"
-            f"**快手品类账号**: {int(ks_count[0][0])}**条**\n"
-            f"**快手推荐流**: {int(ks_feed_count[0][0])}**条**\n"
-            f"**快手小程序**: {int(ks_xcx_count[0][0])}**条**\n"
-            f"**快手搜索**: {int(ks_sou_count[0][0])}**条**\n"
-            f"**相似溯源（xx）**: {int(xx_count[0][0])}**条**\n"
+            f"**抖音品类账号**: {int(dy_count[0][0])}**/1500条**\n"
+            f"**抖音搜索**: {int(dy_sou_count[0][0])}**/1200条**\n"
+            f"**视频号品类账号**: {int(sph_count[0][0])}**/350条**\n"
+            f"**视频号推荐流**: {int(sph_feed_count[0][0])}**/200条**\n"
+            f"**视频号搜索**: {int(sph_sou_count[0][0])}**/100条**\n"
+            f"**快手品类账号**: {int(ks_count[0][0])}**/900条**\n"
+            f"**快手推荐流**: {int(ks_feed_count[0][0])}**/100条**\n"
+            f"**快手小程序**: {int(ks_xcx_count[0][0])}**/?条**\n"
+            f"**快手搜索**: {int(ks_sou_count[0][0])}**/650条**\n"
+            f"**相似溯源（xx）**: {int(xx_count[0][0])}**/200条**\n"
             f"**单点视频**: {int(dd_count[0][0])}**条**\n"
         )
 
@@ -53,9 +53,9 @@ def schedule_tasks():
 
 
 if __name__ == "__main__":
-    schedule_tasks()  # 调用任务调度函数
-    while True:
-        schedule.run_pending()
-        time.sleep(1)  # 每秒钟检查一次
-    # bot_carry_data()
+    # schedule_tasks()  # 调用任务调度函数
+    # while True:
+    #     schedule.run_pending()
+    #     time.sleep(1)  # 每秒钟检查一次
+    bot_carry_data()